uranusjr commented on code in PR #23829:
URL: https://github.com/apache/airflow/pull/23829#discussion_r878969191
##########
airflow/jobs/backfill_job.py:
##########
@@ -627,6 +629,11 @@ def to_keep(key: TaskInstanceKey) -> bool:
for new_ti in new_mapped_tis:
new_ti.set_state(TaskInstanceState.SCHEDULED,
session=session)
+ # Set state to failed for running TIs that are set up for retry if
disable-retry flag is set
+ for ti in list(ti_status.running.values()):
Review Comment:
Why the `list()` call?
--
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]
