diff --git a/tests/test_remote_workflow.py b/tests/test_remote_workflow.py index 929fd206ca..484cbb01a2 100644 --- a/tests/test_remote_workflow.py +++ b/tests/test_remote_workflow.py @@ -345,8 +345,7 @@ def test_remote_workflow_info(local_server): reason="Connecting data from different servers is " "supported starting server version 3.0", ) def test_multi_process_local_remote_local_remote_workflow(server_type_remote_process): - files = examples.download_distributed_files() - + files = examples.download_distributed_files(server=server_type_remote_process) wf = core.Workflow(server=server_type_remote_process) wf.progress_bar = False average = core.operators.math.norm_fc(server=server_type_remote_process) @@ -395,7 +394,6 @@ def test_multi_process_local_remote_local_remote_workflow(server_type_remote_pro for i, wf in enumerate(workflows): local_wf.set_input_name("distrib" + str(i), merge, i) local_wf.connect_with(wf, ("distrib", "distrib" + str(i))) - max_field = local_wf.get_output("tot_output", core.types.field) assert np.allclose(max_field.data, [10.03242272])