Refresh synaptor before triggering it

seung-lab · Mar 21, 2024 · 6d9aaef · 6d9aaef
1 parent 2d5b4e8
commit 6d9aaef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)