From 691fba04f06dc47686e9eadd0b9c3c4dbd96f7d9 Mon Sep 17 00:00:00 2001 From: Ran Lu Date: Tue, 2 Jul 2024 21:56:52 -0400 Subject: [PATCH] The nfs server is not ready yet --- dags/synaptor_dags.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/synaptor_dags.py b/dags/synaptor_dags.py index 54e6ea5a..6fbcd598 100644 --- 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":