This is an automated email from the ASF dual-hosted git repository.
turbaszek pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new e2dc706 Make kill log in DagFileProcessorProcess more informative
(#11124)
e2dc706 is described below
commit e2dc706b08209be9c078918bb4df465724e27335
Author: Tomek Urbaszek <[email protected]>
AuthorDate: Mon Sep 28 00:24:58 2020 +0200
Make kill log in DagFileProcessorProcess more informative (#11124)
---
airflow/jobs/scheduler_job.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
index 0c1c170..269302c 100644
--- a/airflow/jobs/scheduler_job.py
+++ b/airflow/jobs/scheduler_job.py
@@ -243,7 +243,7 @@ class
DagFileProcessorProcess(AbstractDagFileProcessorProcess, LoggingMixin, Mul
raise AirflowException("Tried to kill process before starting!")
if self._process.is_alive() and self._process.pid:
- self.log.warning("Killing PID %s", self._process.pid)
+ self.log.warning("Killing DAGFileProcessorProcess (PID=%d)",
self._process.pid)
os.kill(self._process.pid, signal.SIGKILL)
@property