[AIRFLOW-4750] Log identified zombie task instances

apache · Jun 13, 2019 · d3ad93f · d3ad93f
1 parent e8c5c7a
commit d3ad93f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/airflow/utils/dag_processing.py b/airflow/utils/dag_processing.py
@@ -1268,7 +1268,10 @@ def _find_zombies(self, session):
             )
             self._last_zombie_query_time = timezone.utcnow()
             for ti in tis:
-                zombies.append(SimpleTaskInstance(ti))
+                sti = SimpleTaskInstance(ti)
+                self.log.info("Detected zombie job with dag_id %s, task_id %s, and execution date %s",
+                              sti.dag_id, sti.task_id, sti.execution_date.isoformat())
+                zombies.append(sti)
 
         return zombies