Make kill log in DagFileProcessorProcess more informative (apache#11124)

dferguson992 · Sep 27, 2020 · e2dc706 · e2dc706
1 parent 4d2a787
commit e2dc706
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
@@ -243,7 +243,7 @@ def _kill_process(self) -> None:
             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