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