Merge branch 'master' into dependabot/pip/requirements/wheel-0.45.1

Author: PProfizi

.ci/run_examples.py

@@ -33,13 +33,13 @@
             print(file)
             minimum_version_str = get_example_required_minimum_dpf_version(file)
             if float(server_version) - float(minimum_version_str) < -0.05:
-                print(f"Example skipped as it requires DPF {minimum_version_str}.")
+                print(f"Example skipped as it requires DPF {minimum_version_str}.", flush=True)
                 continue
             try:
                 out = subprocess.check_output([sys.executable, file])
             except subprocess.CalledProcessError as e:
                 sys.stderr.write(str(e.args))
                 if e.returncode != 3221225477:
-                    print(out)
+                    print(out, flush=True)
                     raise e
-            print("PASS")
+            print("PASS", flush=True)

.github/ISSUE_TEMPLATE/bug.yml

@@ -101,7 +101,7 @@ body:
     id: installed-packages
     attributes:
       label: Installed packages
-      description: Run `python -m pip list` to list installed packages
-      placeholder: Paste the output of `python -m pip list` here
+      description: Run `python -m pip freeze` to list installed packages
+      placeholder: Paste the output of `python -m pip freeze` here
     validations:
       required: true

.github/workflows/ci_release.yml

@@ -88,6 +88,7 @@ jobs:
     with:
       ANSYS_VERSION: ${{ github.event.inputs.ansys_version || '251' }}
       python_versions: '["3.10", "3.11"]'
+      DOCSTRING: false
       wheel: false
       wheelhouse: true
       standalone_suffix: ${{ github.event.inputs.standalone_branch_suffix || '.pre0' }}
@@ -109,6 +110,7 @@ jobs:
     with:
       ANSYS_VERSION: ${{ github.event.inputs.ansys_version || '251' }}
       python_versions: '["3.10", "3.11"]'
+      DOCSTRING: false
       wheel: false
       wheelhouse: false
       standalone_suffix: ${{ github.event.inputs.standalone_branch_suffix || '.pre0' }}
@@ -131,6 +133,15 @@ jobs:
       standalone_suffix: ${{ github.event.inputs.standalone_branch_suffix || '.pre0' }}
     secrets: inherit
 
+  retro_242:
+    name: "retro 242"
+    uses: ./.github/workflows/tests.yml
+    with:
+      ANSYS_VERSION: "242"
+      python_versions: '["3.9"]'
+      DOCSTRING: false
+    secrets: inherit
+
   retro_241:
     name: "retro 241"
     uses: ./.github/workflows/tests.yml

.github/workflows/examples.yml

@@ -132,7 +132,6 @@ jobs:
         shell: bash
         working-directory: .ci
         run: |
-          echo on
           python run_examples.py
 
       - name: "Kill all servers"

examples/04-advanced/13-manage_licensing.py

@@ -104,7 +104,7 @@
 # license increment is used, and for what maximum duration.
 
 # Use the LicenseContextManager to block a specific increment for a limited duration
-with dpf.LicenseContextManager(increment_name="preppost", license_timeout_in_seconds=1.0) as lic:
+with dpf.LicenseContextManager(increment_name="preppost", license_timeout_in_seconds=5.0) as lic:
     # Instantiate the licensed operator
     out = op_premium.eval()
     print(out)

pyproject.toml

@@ -44,6 +44,7 @@ plotting = [
     "matplotlib>=3.2",
     # 3D plotting
     "pyvista>=0.32.0",
+    "vtk!=9.4.0",
     # Animations
     "imageio < 2.28.1",
     "imageio-ffmpeg",

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(