From d3ad93f2cc8b9bfd0721a30166012096d5c01f20 Mon Sep 17 00:00:00 2001 From: mclennon Date: Fri, 7 Jun 2019 18:44:55 -0500 Subject: [PATCH] [AIRFLOW-4750] Log identified zombie task instances --- airflow/utils/dag_processing.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/airflow/utils/dag_processing.py b/airflow/utils/dag_processing.py index 82c9082adc854..68f178c1ad380 100644 --- 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