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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
