From c5e058ae1ae67a13b9cc0cb8d7dcf9590c15e1a4 Mon Sep 17 00:00:00 2001 From: Daniel Standish <15932138+dstandish@users.noreply.github.com> Date: Mon, 9 Sep 2024 13:51:02 -0700 Subject: [PATCH] Log info not error in schedule when task has failure (#42116) You have to think about the context where this is emitted. It is emitted in the scheduler. It's not a scheduler error. --- airflow/models/dagrun.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py index db7cb9443a1fe..c932958861f7a 100644 --- a/airflow/models/dagrun.py +++ b/airflow/models/dagrun.py @@ -823,7 +823,7 @@ def recalculate(self) -> _UnfinishedStates: # if all tasks finished and at least one failed, the run failed if not unfinished.tis and any(x.state in State.failed_states for x in tis_for_dagrun_state): - self.log.error("Marking run %s failed", self) + self.log.info("Marking run %s failed", self) self.set_state(DagRunState.FAILED) self.notify_dagrun_state_changed(msg="task_failure")