potiuk commented on a change in pull request #10956:
URL: https://github.com/apache/airflow/pull/10956#discussion_r493511009
##########
File path: airflow/models/dagrun.py
##########
@@ -494,12 +542,13 @@ def verify_integrity(self, session: Session = None):
session.add(ti)
try:
- session.commit()
+ session.flush()
Review comment:
What's the reason for the integrity error here? Is the Integrity error
here still valid if we do not commit to the database? I think flush is not
likely to generate Integrity Error at all.
Shoudl we start caring about isolation level of the transactions we have ?
Will it work when we have different isolation levels set ?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
