File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -345,8 +345,7 @@ def test_remote_workflow_info(local_server):
345345 reason = "Connecting data from different servers is " "supported starting server version 3.0" ,
346346)
347347def test_multi_process_local_remote_local_remote_workflow (server_type_remote_process ):
348- files = examples .download_distributed_files ()
349-
348+ files = examples .download_distributed_files (server = server_type_remote_process )
350349 wf = core .Workflow (server = server_type_remote_process )
351350 wf .progress_bar = False
352351 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
395394 for i , wf in enumerate (workflows ):
396395 local_wf .set_input_name ("distrib" + str (i ), merge , i )
397396 local_wf .connect_with (wf , ("distrib" , "distrib" + str (i )))
398-
399397 max_field = local_wf .get_output ("tot_output" , core .types .field )
400398 assert np .allclose (max_field .data , [10.03242272 ])
401399
You can’t perform that action at this time.
0 commit comments