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 @@ -420,10 +420,13 @@ def test_multi_process_transparent_api_remote_workflow():
420420
421421 workflows .append (wf )
422422
423- local_wf = core .Workflow ()
423+ # Make sure to reuse the same type of remote server as for the previous ones:
424+ # Cannot merge a Workflow from a non-legacy grpc server to a workflow on a legacy grpc server
425+ merge_server = local_servers [len (files )]
426+ local_wf = core .Workflow (server = merge_server )
424427 local_wf .progress_bar = False
425- merge = ops .utility .merge_fields_containers ()
426- min_max = ops .min_max .min_max_fc (merge )
428+ merge = ops .utility .merge_fields_containers (server = merge_server )
429+ min_max = ops .min_max .min_max_fc (merge , server = merge_server )
427430 local_wf .add_operator (merge )
428431 local_wf .add_operator (min_max )
429432 local_wf .set_output_name ("tot_output" , min_max .outputs .field_max )
You can’t perform that action at this time.
0 commit comments