Skip to content

Commit 2b77e98

Browse files
committed
Refactor core._deep_copy
1 parent e246287 commit 2b77e98

File tree

1 file changed

+16
-8
lines changed

1 file changed

+16
-8
lines changed

src/ansys/dpf/core/core.py

Lines changed: 16 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -300,19 +300,27 @@ def _deep_copy(dpf_entity, server=None):
300300
core.Field, core.FieldsContainer, core.MeshedRegion...
301301
"""
302302
from ansys.dpf.core.common import types, types_enum_to_types
303-
from ansys.dpf.core.operators.serialization import serializer_to_string, string_deserializer
303+
from ansys.dpf.core.operators.serialization.serializer_to_string import serializer_to_string
304+
from ansys.dpf.core.operators.serialization.string_deserializer import string_deserializer
304305

305306
entity_server = dpf_entity._server if hasattr(dpf_entity, "_server") else None
306-
serializer = serializer_to_string(server=entity_server)
307-
serializer.connect(1, dpf_entity)
308-
deserializer = string_deserializer(server=server)
309-
stream_type = 1 if server_meet_version("8.0", serializer._server) else 0
310-
serializer.connect(-1, stream_type)
307+
# Set stream_type to 1 (binary) if available, else use 0 (string)
308+
stream_type = 1 if server_meet_version(required_version="8.0", server=entity_server) else 0
309+
310+
serializer = serializer_to_string(
311+
stream_type=stream_type,
312+
server=entity_server,
313+
)
314+
serializer.connect(0, dpf_entity)
311315
if stream_type == 1:
312316
out = serializer.get_output(0, types.bytes)
313317
else:
314-
out = serializer.outputs.serialized_string # Required for retro with 241
315-
deserializer.connect(-1, stream_type)
318+
out = serializer.outputs.serialized_string1() # Required for retro with 241
319+
320+
deserializer = string_deserializer(
321+
stream_type=stream_type,
322+
server=server,
323+
)
316324
deserializer.connect(0, out)
317325
type_map = types_enum_to_types()
318326
output_type = list(type_map.keys())[list(type_map.values()).index(dpf_entity.__class__)]

0 commit comments

Comments
 (0)