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)