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")