Compatible with 3.7 onwards (#10)

Author: DeepanshuA

.github/workflows/pr-validation.yml

@@ -16,7 +16,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.9","3.10", "3.11"]
+        python-version: ["3.7", "3.8", "3.9", "3.10", "3.11"]
 
     steps:
     - uses: actions/checkout@v3
@@ -32,6 +32,7 @@ jobs:
     - name: Lint with flake8
       run: |
         flake8 . --count --show-source --statistics --exit-zero
+      if: matrix.python-version != '3.7'
     - name: Pytest unit tests
       run: |
         pytest -m "not e2e" --verbose

README.md

@@ -133,7 +133,7 @@ Orchestrations can specify retry policies for activities and sub-orchestrations.
 
 ### Prerequisites
 
-- Python 3.10 or higher
+- Python 3.7 or higher (Python 3.8 or higher is recommended when running tests or making contributions)
 - A Durable Task-compatible sidecar, like [Dapr Workflow](https://docs.dapr.io/developing-applications/building-blocks/workflow/workflow-overview/)
 
 ### Installing the Durable Task Python client SDK

durabletask/worker.py

@@ -28,8 +28,8 @@ class _Registry:
     activities: Dict[str, task.Activity]
 
     def __init__(self):
-        self.orchestrators = dict[str, task.Orchestrator]()
-        self.activities = dict[str, task.Activity]()
+        self.orchestrators = {}
+        self.activities = {}
 
     def add_orchestrator(self, fn: task.Orchestrator) -> str:
         if fn is None:
@@ -228,8 +228,8 @@ def __init__(self, instance_id: str):
         self._is_replaying = True
         self._is_complete = False
         self._result = None
-        self._pending_actions = dict[int, pb.OrchestratorAction]()
-        self._pending_tasks = dict[int, task.CompletableTask]()
+        self._pending_actions: Dict[int, pb.OrchestratorAction] = {}
+        self._pending_tasks: Dict[int, task.CompletableTask] = {}
         self._sequence_number = 0
         self._current_utc_datetime = datetime(1000, 1, 1)
         self._instance_id = instance_id
@@ -736,7 +736,7 @@ def _get_new_event_summary(new_events: Sequence[pb.HistoryEvent]) -> str:
     elif len(new_events) == 1:
         return f"[{new_events[0].WhichOneof('eventType')}]"
     else:
-        counts = dict[str, int]()
+        counts: Dict[str, int] = {}
         for event in new_events:
             event_type = event.WhichOneof('eventType')
             counts[event_type] = counts.get(event_type, 0) + 1
@@ -750,7 +750,7 @@ def _get_action_summary(new_actions: Sequence[pb.OrchestratorAction]) -> str:
     elif len(new_actions) == 1:
         return f"[{new_actions[0].WhichOneof('orchestratorActionType')}]"
     else:
-        counts = dict[str, int]()
+        counts: Dict[str, int] = {}
         for action in new_actions:
             action_type = action.WhichOneof('orchestratorActionType')
             counts[action_type] = counts.get(action_type, 0) + 1

pyproject.toml

@@ -9,7 +9,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "durabletask"
-version = "0.1.0"
+version = "0.1.0-alpha.3"
 description = "A Durable Task Client SDK for Python"
 keywords = [
     "durable",
@@ -21,7 +21,7 @@ classifiers = [
   "Programming Language :: Python :: 3",
   "License :: OSI Approved :: MIT License",
 ]
-requires-python = ">=3.9"
+requires-python = ">=3.7"
 license = {file = "LICENSE"}
 readme = "README.md"
 dependencies = [