ephraimbuddy commented on issue #27824: URL: https://github.com/apache/airflow/issues/27824#issuecomment-1329062850
Looks like this is all we need: ```diff diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py index 9e02f4775f..f3fc068b04 100644 --- a/airflow/models/dagrun.py +++ b/airflow/models/dagrun.py @@ -716,6 +716,7 @@ class DagRun(Base, LoggingMixin): # During expansion we may change some tis into non-schedulable # states, so we need to re-compute. if expansion_happened: + changed_tis = True new_unfinished_tis = [t for t in unfinished_tis if t.state in State.unfinished] finished_tis.extend(t for t in unfinished_tis if t.state in State.finished) unfinished_tis = new_unfinished_tis ``` in addition to @ashb's previous fix -- 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: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org