[GitHub] [airflow] ashb commented on a change in pull request #11730: Stop scheduler from thinking that upstream_failed tasks are running

ashb commented on a change in pull request #11730: URL: https://github.com/apache/airflow/pull/11730#discussion_r509700963 ## File path: airflow/utils/state.py ## @@ -114,6 +114,16 @@ def color_fg(cls, state): have been interrupted; in any case, it is no longer running.

[GitHub] [airflow] ashb commented on a change in pull request #11730: Stop scheduler from thinking that upstream_failed tasks are running

ashb commented on a change in pull request #11730: URL: https://github.com/apache/airflow/pull/11730#discussion_r509684070 ## File path: airflow/utils/state.py ## @@ -114,6 +114,16 @@ def color_fg(cls, state): have been interrupted; in any case, it is no longer running.

[GitHub] [airflow] ashb commented on a change in pull request #11730: Stop scheduler from thinking that upstream_failed tasks are running

ashb commented on a change in pull request #11730: URL: https://github.com/apache/airflow/pull/11730#discussion_r509682544 ## File path: airflow/models/dagrun.py ## @@ -387,7 +387,7 @@ def update_state( ti.task = dag.get_task(ti.task_id) unfinished_tasks

[GitHub] [airflow] ashb commented on a change in pull request #11730: Stop scheduler from thinking that upstream_failed tasks are running

ashb commented on a change in pull request #11730: URL: https://github.com/apache/airflow/pull/11730#discussion_r509682312 ## File path: airflow/jobs/scheduler_job.py ## @@ -1473,7 +1473,7 @@ def _do_scheduling(self, session) -> int: func.count(TI.execution_dat