Skip to content

Commit 1687333

Browse files
feat: add Operator.id property
feat: add test for Operator.id
1 parent 87aacb8 commit 1687333

File tree

2 files changed

+26
-0
lines changed

2 files changed

+26
-0
lines changed

src/ansys/dpf/core/dpf_operator.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,7 @@ def __init__(self, name=None, config=None, server=None, operator=None):
127127
self._internal_obj = None
128128
self._description = None
129129
self._inputs = None
130+
self._id = None
130131

131132
# step 1: get server
132133
self._server = server_module.get_or_create_server(
@@ -657,6 +658,15 @@ def config(self, value):
657658
"""
658659
self._api.operator_set_config(self, value)
659660

661+
@property
662+
def id(self):
663+
if self._id is None:
664+
operator_id_op = Operator("operator_id", server=self._server)
665+
operator_id_op.connect_operator_as_input(0, self)
666+
self._id = operator_id_op.outputs.id()
667+
668+
return self._id
669+
660670
@property
661671
def inputs(self):
662672
"""Inputs connected to the operator.

tests/test_operator.py

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1424,3 +1424,19 @@ def test_operator_input_output_streams(server_in_process, simple_bar):
14241424
time_provider.connect(pin=3, inpt=streams)
14251425
times = time_provider.outputs.time_freq_support()
14261426
assert times
1427+
1428+
1429+
@pytest.mark.skipif(
1430+
not conftest.SERVERS_VERSION_GREATER_THAN_OR_EQUAL_TO_10_0,
1431+
reason="Operator `workflow_to_workflow_topology` does not exist below 10.0",
1432+
)
1433+
def test_operator_id(server_type):
1434+
ids = set()
1435+
1436+
for _ in range(10):
1437+
op = ops.utility.forward(server=server_type)
1438+
1439+
assert op.id >= 0
1440+
assert op.id not in ids
1441+
1442+
ids.add(op.id)

0 commit comments

Comments
 (0)