@@ -208,7 +208,7 @@ def _create_initial_result_workflow(
208
208
209
209
initial_result_workflow .add_operator (initial_result_op )
210
210
211
- forward_shell_layer_op = operators .utility .forward ()
211
+ forward_shell_layer_op = operators .utility .forward (server = server )
212
212
initial_result_workflow .add_operator (forward_shell_layer_op )
213
213
initial_result_workflow .set_input_name (_WfNames .shell_layer , forward_shell_layer_op )
214
214
@@ -226,7 +226,7 @@ def _create_initial_result_workflow(
226
226
name = "merge::solid_shell_fields"
227
227
)
228
228
initial_result_workflow .add_operator (merge_shell_solid_fields )
229
- shell_layer_op = operators .utility .change_shell_layers ()
229
+ shell_layer_op = operators .utility .change_shell_layers (server = server )
230
230
shell_layer_op .inputs .merge (True )
231
231
initial_result_workflow .add_operator (shell_layer_op )
232
232
@@ -310,7 +310,9 @@ def _enrich_mesh_with_property_fields(
310
310
property_names : list [str ],
311
311
streams_provider : StreamsContainer ,
312
312
):
313
- property_operator = operators .metadata .property_field_provider_by_name ()
313
+ property_operator = operators .metadata .property_field_provider_by_name (
314
+ server = mesh ._server
315
+ )
314
316
property_operator .inputs .streams_container (streams_provider )
315
317
316
318
for property_name in property_names :
@@ -323,7 +325,9 @@ def _enrich_mesh_with_property_fields(
323
325
# Rescope the property field to the element scoping of the mesh
324
326
# to ensure the split by property operator works correctly
325
327
rescope_op = operators .scoping .rescope_property_field (
326
- mesh_scoping = mesh .elements .scoping , fields = property_field
328
+ mesh_scoping = mesh .elements .scoping ,
329
+ fields = property_field ,
330
+ server = mesh ._server ,
327
331
)
328
332
329
333
mesh .set_property_field (
@@ -348,6 +352,9 @@ def _create_split_scope_by_body_workflow(server, body_defining_properties: list[
348
352
split_scope_by_body_wf .set_output_name (
349
353
_WfNames .scoping , split_scop_op .outputs .mesh_scoping
350
354
)
355
+ split_scope_by_body_wf .set_output_name (
356
+ _WfNames .result_scoping_by_body , split_scop_op .outputs .mesh_scoping
357
+ )
351
358
return split_scope_by_body_wf
352
359
353
360
@@ -362,14 +369,14 @@ def _create_rescoping_workflow(server, rescoping: _Rescoping):
362
369
363
370
rescoping_wf = Workflow (server = server )
364
371
365
- transpose_scoping_op = operators .scoping .transpose ()
372
+ transpose_scoping_op = operators .scoping .transpose (server = server )
366
373
rescoping_wf .add_operator (transpose_scoping_op )
367
374
transpose_scoping_op .inputs .requested_location (rescoping .requested_location )
368
375
rescoping_wf .set_input_name (
369
376
_WfNames .mesh , transpose_scoping_op .inputs .meshed_region
370
377
)
371
378
372
- rescoping_op = operators .scoping .rescope_fc ()
379
+ rescoping_op = operators .scoping .rescope_fc (server = server )
373
380
rescoping_wf .add_operator (rescoping_op )
374
381
rescoping_op .inputs .mesh_scoping (
375
382
transpose_scoping_op .outputs .mesh_scoping_as_scoping
0 commit comments