Skip to content

Commit

Permalink
Log info not error in schedule when task has failure (apache#42116)
Browse files Browse the repository at this point in the history
You have to think about the context where this is emitted.  It is emitted in the scheduler.  It's not a scheduler error.
  • Loading branch information
dstandish authored Sep 9, 2024
1 parent ff718bd commit c5e058a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/models/dagrun.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")

Expand Down

0 comments on commit c5e058a

Please sign in to comment.