Scale clusters correctly

Seggraph may use different number of workers, notify synaptor image with the tag
seung-lab · Mar 7, 2024 · ee83598 · ee83598
1 parent 1606d1f
commit ee83598
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dags/synaptor_ops.py b/dags/synaptor_ops.py
@@ -242,6 +242,8 @@ def generate_op(
         f" --queueurl {broker_url}"
         f" --queuename {task_queue_name}"
     )
+    if taskname == "self_destruct":
+        command += f" --clusterkey {tag}"
 
     # these variables will be mounted in the containers
     variables = add_secrets_if_defined(["synaptor_param.json"])