From 6d9aaefb3154cb917404ff580383677b9dc01b1b Mon Sep 17 00:00:00 2001 From: Ran Lu Date: Thu, 21 Mar 2024 16:15:25 -0400 Subject: [PATCH] Refresh synaptor before triggering it --- slackbot/airflow_api.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/slackbot/airflow_api.py b/slackbot/airflow_api.py index a529a5ff..6c700bbd 100644 --- a/slackbot/airflow_api.py +++ b/slackbot/airflow_api.py @@ -106,7 +106,7 @@ def wait_for_dag_refresh(dag_id): def run_dag(dag_id, wait_for_completion=False): - dags_need_refresh = ["segmentation", "chunkflow_worker"] + dags_need_refresh = ["segmentation", "chunkflow_worker", "synaptor"] if dag_id in dags_need_refresh: wait_for_dag_refresh(dag_id) dagrun = run_in_executor(__run_dag, dag_id)