Merge branch 'master' into maint/bug_template_pip_freeze

Author: PProfizi

requirements/requirements_docs.txt

@@ -14,3 +14,4 @@ sphinx-notfound-page==1.0.4
 sphinx-reredirects==0.1.3
 sphinx_design==0.6.1
 sphinxcontrib-napoleon==0.7
+vtk==9.3.1

requirements/requirements_test.txt

@@ -7,3 +7,4 @@ pytest-cov==5.0.0
 pytest-order==1.3.0
 pytest-rerunfailures==15.0
 pyvista==0.44.1
+vtk==9.3.1

src/ansys/dpf/core/any.py

@@ -123,6 +123,7 @@ def _type_to_new_from_get_as_method(self, obj):
             custom_type_field,
             collection,
             workflow,
+            dpf_operator,
         )
 
         if issubclass(obj, int):
@@ -196,6 +197,11 @@ def _type_to_new_from_get_as_method(self, obj):
                 self._api.any_new_from_int_collection,
                 self._api.any_get_as_int_collection,
             )
+        elif issubclass(obj, dpf_operator.Operator):
+            return (
+                self._api.any_new_from_operator,
+                self._api.any_get_as_operator,
+            )
 
     @staticmethod
     def new_from(obj, server=None):

src/ansys/dpf/core/dpf_operator.py

@@ -121,7 +121,7 @@ class Operator:
 
     """
 
-    def __init__(self, name, config=None, server=None):
+    def __init__(self, name=None, config=None, server=None, operator=None):
         """Initialize the operator with its name by connecting to a stub."""
         self.name = name
         self._internal_obj = None
@@ -136,14 +136,29 @@ def __init__(self, name, config=None, server=None):
         # step 2: get api
         self._api_instance = None  # see _api property
 
-        # step3: init environment
+        # step 3: init environment
         self._api.init_operator_environment(self)  # creates stub when gRPC
 
-        # step4: if object exists: take instance, else create it (server)
-        if self._server.has_client():
-            self._internal_obj = self._api.operator_new_on_client(self.name, self._server.client)
+        # step 4: if object exists, take the instance, else create it
+        if operator is not None:
+            if isinstance(operator, Operator):
+                core_api = self._server.get_api_for_type(
+                    capi=data_processing_capi.DataProcessingCAPI,
+                    grpcapi=data_processing_grpcapi.DataProcessingGRPCAPI,
+                )
+                core_api.init_data_processing_environment(self)
+                self._internal_obj = core_api.data_processing_duplicate_object_reference(operator)
+                self.name = operator.name
+            else:
+                self._internal_obj = operator
+                self.name = self._api.operator_name(self)
         else:
-            self._internal_obj = self._api.operator_new(self.name)
+            if self._server.has_client():
+                self._internal_obj = self._api.operator_new_on_client(
+                    self.name, self._server.client
+                )
+            else:
+                self._internal_obj = self._api.operator_new(self.name)
 
         if self._internal_obj is None:
             raise KeyError(

src/ansys/dpf/gate/any_grpcapi.py

@@ -42,6 +42,7 @@ def _type_to_message_type():
             custom_type_field,
             collection_base,
             workflow,
+            dpf_operator,
         )
 
         return [(int, base_pb2.Type.INT),
@@ -58,6 +59,7 @@ def _type_to_message_type():
                 (workflow.Workflow, base_pb2.Type.WORKFLOW),
                 (collection_base.CollectionBase, base_pb2.Type.COLLECTION, base_pb2.Type.ANY),
                 (dpf_vector.DPFVectorInt, base_pb2.Type.COLLECTION, base_pb2.Type.INT),
+                (dpf_operator.Operator, base_pb2.Type.OPERATOR),
                 ]
 
     @staticmethod
@@ -145,6 +147,10 @@ def any_get_as_int_collection(any):
     def any_get_as_workflow(any):
         return AnyGRPCAPI._get_as(any).workflow
 
+    @staticmethod
+    def any_get_as_operator(any):
+        return AnyGRPCAPI._get_as(any).operator
+
     @staticmethod
     def _new_from(any, client=None):
         from ansys.grpc.dpf import dpf_any_pb2
@@ -230,3 +236,7 @@ def any_new_from_data_tree(any):
     @staticmethod
     def any_new_from_workflow(any):
         return AnyGRPCAPI._new_from(any, any._server)
+
+    @staticmethod
+    def any_new_from_operator(any):
+        return AnyGRPCAPI._new_from(any, any._server)

src/ansys/dpf/gate/operator_grpcapi.py

@@ -51,6 +51,10 @@ def get_list(op):
     def operator_get_config(op):
         return OperatorGRPCAPI.get_list(op).config
 
+    @staticmethod
+    def operator_name(op):
+        return OperatorGRPCAPI.get_list(op).op_name
+
     @staticmethod
     def update_init(op, pin):
         from ansys.grpc.dpf import operator_pb2