Skip to content

Commit

Permalink
[AIRFLOW-6177] Log DAG processors timeout event at error level, not i…
Browse files Browse the repository at this point in the history
…nfo (#6731)

This case prevents a DAG from being scheduled so should be an error.
  • Loading branch information
robinedwards authored and XD-DENG committed Dec 6, 2019
1 parent ce873af commit fb929eb
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/utils/dag_processing.py
Original file line number Diff line number Diff line change
Expand Up @@ -1111,7 +1111,7 @@ def _kill_timed_out_processors(self):
for file_path, processor in self._processors.items():
duration = now - processor.start_time
if duration > self._processor_timeout:
self.log.info(
self.log.error(
"Processor for %s with PID %s started at %s has timed out, "
"killing it.",
file_path, processor.pid, processor.start_time.isoformat())
Expand Down

0 comments on commit fb929eb

Please sign in to comment.