use runner most recent job

apache · Sep 27, 2023 · ef577e7 · ef577e7
1 parent 0755b1c
commit ef577e7
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/airflow/models/dag.py b/airflow/models/dag.py
@@ -3980,12 +3980,10 @@ def get_current_dag(cls) -> DAG | None:
 
 
 def _triggerer_is_healthy():
-    from airflow.api.common.airflow_health import get_airflow_health
+    from airflow.jobs.triggerer_job_runner import TriggererJobRunner
 
-    health = get_airflow_health()
-    if health["triggerer"]["status"] != "healthy":
-        return False
-    return True
+    job = TriggererJobRunner.most_recent_job()
+    return job and job.is_alive()
 
 
 def _run_task(ti: TaskInstance, session) -> TaskReturnCode | None: