shaealh opened a new pull request, #65924: URL: https://github.com/apache/airflow/pull/65924
Fixes #63697 When checking premature task instances, the scheduler can use a stale list of finished task instances captured earlier in the scheduling loop. If another process changes task states meanwhile, this can cause the scheduler to propagate upstream_failed based on outdated upstream state. This changes the premature-TI dependency check to re-query finished task instances before allowing flag_upstream_failed=True dependency evaluation to write terminal states. Added a regression test that simulates separate scheduler/API SQLAlchemy sessions. -- 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]
