Merge pull request #253 from AndroxxTraxxon/master

update builtin collections imports to be forward-compatible with Python3.10+

Author: arm4b

.coveragerc

@@ -21,6 +21,5 @@ exclude_lines =
     if __name__ == .__main__.:
 
 ignore_errors = True
+omit = orquesta/tests/*
 
-omit =
-	tests/*

.github/workflows/tox.yml

@@ -12,11 +12,10 @@ on:
 
 jobs:
   tests:
-    #python 3.6 not available on ubuntu-latest
     runs-on: ubuntu-20.04
     strategy:
       matrix:
-        python-version: ["3.6", "3.8"]
+        python-version: ["3.6", "3.8", "3.9", "3.10", "3.11"]
     steps:
       - name: Checkout repository
         uses: actions/checkout@v4
@@ -30,5 +29,4 @@ jobs:
           pip install -r requirements-ci.txt
           make clean reqs schemas
       - name: "Run tox for ${{ matrix.python-version }}"
-        run: |
-          make check
+        run: make check

CHANGELOG.rst

@@ -7,6 +7,12 @@ In Development
 Changed
 ~~~~~~~
 
+* Update deprecated `collections` imports to `collections.abc` to be forward-compatible with Python3.10
+  Contributed by @AndroxxTraxxon
+* Migrate from `nosetest` to `pytest` for Python test runner.
+  Contributed by @AndroxxTraxxon
+* Add Python versions 3.9, 3.10, and 3.11 to the test matrix
+  Contributed by @AndroxxTraxxon
 * Update networkx >=2.6 for Python 3.8 to fix insecure deserialization #255 (improvement)
   Contributed by @Stealthii
 * Update jsonschema requirements to allow 3.2 (improvement)

orquesta/conducting.py

@@ -370,7 +370,6 @@ def log_entry(
         result=None,
         data=None,
     ):
-
         # Check entry type.
         if entry_type not in ["info", "warn", "error"]:
             raise exc.WorkflowLogEntryError('The log entry type "%s" is not valid.' % entry_type)

orquesta/expressions/functions/workflow.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import collections
+import collections.abc
 
 from orquesta import constants
 from orquesta import exceptions as exc
@@ -117,8 +117,8 @@ def item_(context, key=None):
     if not key:
         return current_item
 
-    if not isinstance(current_item, collections.Mapping):
-        raise exc.ExpressionEvaluationException("Item is not type of collections.Mapping.")
+    if not isinstance(current_item, collections.abc.Mapping):
+        raise exc.ExpressionEvaluationException("Item is not type of collections.abc.Mapping.")
 
     if key not in current_item:
         raise exc.ExpressionEvaluationException('Item does not have key "%s".' % key)

orquesta/specs/base.py

@@ -13,7 +13,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import collections
+import collections.abc
 import inspect
 import json
 import jsonschema
@@ -613,7 +613,7 @@ def update(self, *args, **kwargs):
         raise NotImplementedError()
 
 
-class SequenceSpec(Spec, collections.MutableSequence):
+class SequenceSpec(Spec, collections.abc.MutableSequence):
     def __init__(self, spec, name=None, member=False):
         super(SequenceSpec, self).__init__(spec, name=name, member=member)
 

orquesta/tests/hacking/import_aliases_rule.py

@@ -59,7 +59,6 @@
 
 
 def get_alias(logical_line):
-
     parts = logical_line.split()
 
     if (
@@ -68,7 +67,6 @@ def get_alias(logical_line):
         and parts[1] != "__future__"
         and not core.is_import_exception(parts[1])
     ):
-
         # from path.to.module import module
         if len(parts) == 4:
             return ".".join([parts[1], parts[3]]), None

orquesta/tests/unit/base.py

@@ -156,7 +156,6 @@ def format_task_item(
         items_count=None,
         items_concurrency=None,
     ):
-
         if not actions and items_count is None:
             actions = [{"action": spec.action, "input": spec.input}]
 
@@ -285,7 +284,6 @@ def assert_task_items(
         concurrency=None,
         mock_ac_ex_results=None,
     ):
-
         # Set up test cases.
         tests = list(zip(mock_ac_ex_statuses, expected_task_statuses, expected_workflow_statuses))
         tk_ex_result = [None] * len(items)

orquesta/tests/unit/conducting/native/test_task_rendering_for_with_items.py

@@ -81,7 +81,7 @@ def test_bad_item_type(self):
                 "type": "error",
                 "message": (
                     "YaqlEvaluationException: Unable to evaluate expression '<% item(x) %>'. "
-                    "ExpressionEvaluationException: Item is not type of collections.Mapping."
+                    "ExpressionEvaluationException: Item is not type of collections.abc.Mapping."
                 ),
                 "task_id": "task1",
                 "route": 0,

orquesta/tests/unit/specs/native/test_workflow_rehearsal_spec.py

@@ -211,8 +211,7 @@ def test_init_test_spec_with_mock_action_execution_yml_result_path(self):
     def test_init_test_spec_with_base_path(self):
         shutil.copy(self.get_wf_file_path("sequential"), "/tmp/sequential.yaml")
 
-        fd, path = tempfile.mkstemp(suffix=".json")
-
+        fd, path = tempfile.mkstemp(suffix=".json", dir="/tmp")
         with os.fdopen(fd, "w") as tmp:
             tmp.write('{"foo": "bar"}\n')