Drain new synaptor queues when user cancels

seung-lab · Jul 2, 2024 · 15d663e · 15d663e
1 parent 1814272
commit 15d663e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/slackbot/cancel_run_commands.py b/slackbot/cancel_run_commands.py
@@ -64,6 +64,9 @@ def cancel_run(msg):
     drain_messages(broker_url, "custom-gpu")
     drain_messages(broker_url, "chunkflow")
     drain_messages(broker_url, "synaptor")
+    drain_messages(broker_url, "synaptor-cpu-tasks")
+    drain_messages(broker_url, "synaptor-gpu-tasks")
+    drain_messages(broker_url, "synaptor-seggraph-tasks")
     drain_messages(broker_url, "deepem-gpu")
     time.sleep(10)