File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -457,10 +457,13 @@ def test_multi_process_with_names_transparent_api_remote_workflow():
457457
458458 workflows .append (wf )
459459
460- local_wf = core .Workflow ()
460+ # Make sure to reuse the same type of remote server as for the previous ones:
461+ # Cannot merge a Workflow from a non-legacy grpc server to a workflow on a legacy grpc server
462+ merge_server = local_servers [len (files )]
463+ local_wf = core .Workflow (server = merge_server )
461464 local_wf .progress_bar = False
462- merge = ops .utility .merge_fields_containers ()
463- min_max = ops .min_max .min_max_fc (merge )
465+ merge = ops .utility .merge_fields_containers (server = merge_server )
466+ min_max = ops .min_max .min_max_fc (merge , server = merge_server )
464467 local_wf .add_operator (merge )
465468 local_wf .add_operator (min_max )
466469 local_wf .set_output_name ("tot_output" , min_max .outputs .field_max )
You can’t perform that action at this time.
0 commit comments