The nfs server is not ready yet

seung-lab · Jul 3, 2024 · 691fba0 · 691fba0
1 parent 2fe5cae
commit 691fba0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/synaptor_dags.py b/dags/synaptor_dags.py
@@ -95,7 +95,7 @@ def fill_dag(dag: DAG, tasklist: list[Task], collect_metrics: bool = True) -> DA
     drain_tasks = [drain_op(dag, task_queue_name=f"synaptor-{t}-tasks") for t in ["cpu", "gpu", "seggraph"]]
     init_cloudvols = manager_op(dag, "init_cloudvols", image=SYNAPTOR_IMAGE)
 
-    start_nfs_server >> drain_tasks >> init_cloudvols
+    drain_tasks >> init_cloudvols
 
     curr_operator = init_cloudvols
     if WORKFLOW_PARAMS.get("workspacetype", "File") == "Database":