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.

(cherry picked from commit fb929eb)
  • Loading branch information
robinedwards authored and kaxil committed Dec 12, 2019
1 parent 022e723 commit 13e5798
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 @@ -1327,7 +1327,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.",
processor.file_path, processor.pid, processor.start_time.isoformat())
Expand Down

0 comments on commit 13e5798

Please sign in to comment.