henry3260 commented on code in PR #67900:
URL: https://github.com/apache/airflow/pull/67900#discussion_r3350782082
##########
airflow-core/src/airflow/models/backfill.py:
##########
@@ -653,7 +653,7 @@ def _create_backfill(
triggering_user_name=triggering_user_name,
)
session.add(br)
- session.commit()
+ session.flush()
Review Comment:
I have a idea but i'm not sure if it cause deadlock (should check call
paths) One possible approach is to lock the corresponding DagModel row with
`with_row_locks() `before checking active backfills. but just for PostgreSQL
and MySQL
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
