Remove useless logging line (#25347)

(cherry picked from commit 5efe6f3)
apache · Aug 15, 2022 · aff5994 · aff5994
1 parent 626814a
commit aff5994
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py
@@ -647,9 +647,10 @@ def _filter_tis_and_exclude_removed(dag: "DAG", tis: List[TI]) -> Iterable[TI]:
                 try:
                     ti.task = dag.get_task(ti.task_id)
                 except TaskNotFound:
-                    self.log.error("Failed to get task for ti %s. Marking it as removed.", ti)
-                    ti.state = State.REMOVED
-                    session.flush()
+                    if ti.state != State.REMOVED:
+                        self.log.error("Failed to get task for ti %s. Marking it as removed.", ti)
+                        ti.state = State.REMOVED
+                        session.flush()
                 else:
                     yield ti