From aff5994e2bd30d5288adb7489ab734c2f6583757 Mon Sep 17 00:00:00 2001 From: Jorrick Sleijster Date: Thu, 28 Jul 2022 01:28:22 +0200 Subject: [PATCH] Remove useless logging line (#25347) (cherry picked from commit 5efe6f34fd4a00f388d2979a708c90884f2e09ac) --- airflow/models/dagrun.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py index 0e7d4e137429b..1b746e8a06ec6 100644 --- 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