disable nglink

seung-lab · Jul 3, 2024 · 43500cb · 43500cb
1 parent 2ebf305
commit 43500cb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dags/synaptor_dags.py b/dags/synaptor_dags.py
@@ -125,8 +125,8 @@ def fill_dag(dag: DAG, tasklist: list[Task], collect_metrics: bool = True) -> DA
         param["Volumes"]["image"],
         tuple(map(int, param["Dimensions"]["voxelres"].split(","))),
     )
-    curr_operator >> nglink
-    scale_down_cluster(dag, curr_cluster, nglink)
+    # curr_operator >> nglink
+    scale_down_cluster(dag, curr_cluster, curr_operator)
 
     return dag