Support for older python versions (#242)

Co-authored-by: Miguel Prieto <miguel.prieto@orkes.io>

Author: v1r3n

Dockerfile

@@ -1,6 +1,6 @@
 ARG SDK_ORIGIN=no_sdk
 
-FROM python:3.11-alpine as python_base
+FROM python:3.7-alpine as python_base
 RUN apk add --no-cache tk
 
 FROM python_base as python_test_base

README.md

@@ -691,7 +691,7 @@ get_workflow(workflow_id: str, include_tasks: Optional[bool] = True) -> Workflow
 Variables inside a workflow are the equivalent of global variables in a program.
 
 ```python
-update_variables(self, workflow_id: str, variables: dict[str, object] = {})
+update_variables(self, workflow_id: str, variables: Dict[str, object] = {})
 ```
 
 ### Terminate Running Workflows

examples/orkes/copilot/open_ai_copilot.py

@@ -2,7 +2,7 @@
 import os
 import random
 import string
-from typing import List
+from typing import List, Dict
 
 from conductor.client.ai.configuration import LLMProvider
 from conductor.client.ai.integrations import OpenAIConfig
@@ -71,7 +71,7 @@ def send_email(customer: list[Customer], promo_code: str) -> str:
 
 
 @worker_task(task_definition_name='create_workflow')
-def create_workflow(steps: list[str], inputs: dict[str, object]) -> dict:
+def create_workflow(steps: list[str], inputs: Dict[str, object]) -> dict:
     executor = OrkesClients().get_workflow_executor()
     workflow = ConductorWorkflow(executor=executor, name='copilot_execution', version=1)
 

src/conductor/client/http/api_client.py

@@ -6,6 +6,7 @@
 import tempfile
 import time
 from typing import Dict
+import uuid
 
 import six
 import urllib3
@@ -198,6 +199,8 @@ def sanitize_for_serialization(self, obj):
                          for sub_obj in obj)
         elif isinstance(obj, (datetime.datetime, datetime.date)):
             return obj.isoformat()
+        elif isinstance(obj, uuid.UUID): # needed for compatibility with Python 3.7
+            return str(obj) # Convert UUID to string
 
         if isinstance(obj, dict) or isinstance(obj, CaseInsensitiveDict):
             obj_dict = obj

src/conductor/client/http/models/schema_def.py

@@ -1,5 +1,6 @@
 import pprint
 from enum import Enum
+from typing import Dict
 
 import six
 
@@ -30,7 +31,7 @@ class SchemaDef(object):
         'external_ref': 'externalRef'
     }
 
-    def __init__(self, name : str =None, version : int =1, type : SchemaType =None, data : dict[str, object] =None,
+    def __init__(self, name : str =None, version : int =1, type : SchemaType =None, data : Dict[str, object] =None,
                  external_ref : str =None):  # noqa: E501
         self._name = None
         self._version = None
@@ -104,20 +105,20 @@ def type(self, type:SchemaType):
         self._type = type
 
     @property
-    def data(self) -> dict[str, object]:
+    def data(self) -> Dict[str, object]:
         """Gets the data of this SchemaDef.  # noqa: E501
 
         :return: The data of this SchemaDef.  # noqa: E501
-        :rtype: dict[str, object]
+        :rtype: Dict[str, object]
         """
         return self._data
 
     @data.setter
-    def data(self, data: dict[str, object]):
+    def data(self, data: Dict[str, object]):
         """Sets the data of this SchemaDef.
 
         :param data: The data of this SchemaDef.  # noqa: E501
-        :type: dict[str, object]
+        :type: Dict[str, object]
         """
         self._data = data
 

src/conductor/client/http/models/state_change_event.py

@@ -1,5 +1,5 @@
 from enum import Enum
-from typing import Union, List
+from typing import Union, List, Dict
 from typing_extensions import Self
 
 
@@ -14,15 +14,15 @@ class StateChangeEventType(Enum):
 class StateChangeEvent:
     swagger_types = {
         'type': 'str',
-        'payload': 'dict[str, object]'
+        'payload': 'Dict[str, object]'
     }
 
     attribute_map = {
         'type': 'type',
         'payload': 'payload'
     }
 
-    def __init__(self, type: str, payload: dict[str, object]) -> None:
+    def __init__(self, type: str, payload: Dict[str, object]) -> None:
         self._type = type
         self._payload = payload
 
@@ -39,7 +39,7 @@ def payload(self):
         return self._payload
 
     @payload.setter
-    def payload(self, payload: dict[str, object]) -> Self:
+    def payload(self, payload: Dict[str, object]) -> Self:
         self._payload = payload
 
 

src/conductor/client/http/models/workflow_state_update.py

@@ -1,3 +1,4 @@
+from typing import Dict
 import pprint
 import re  # noqa: F401
 
@@ -31,7 +32,7 @@ class WorkflowStateUpdate(object):
     }
 
     def __init__(self, task_reference_name: str = None, task_result: TaskResult = None,
-                 variables: dict[str, object] = None):  # noqa: E501
+                 variables: Dict[str, object] = None):  # noqa: E501
         """WorkflowStateUpdate - a model defined in Swagger"""  # noqa: E501
         self._task_reference_name = None
         self._task_result = None
@@ -86,7 +87,7 @@ def task_result(self, task_result: TaskResult):
         self._task_result = task_result
 
     @property
-    def variables(self) -> dict[str, object]:
+    def variables(self) -> Dict[str, object]:
         """Gets the variables of this WorkflowStateUpdate.  # noqa: E501
 
 
@@ -96,7 +97,7 @@ def variables(self) -> dict[str, object]:
         return self._variables
 
     @variables.setter
-    def variables(self, variables: dict[str, object]):
+    def variables(self, variables: Dict[str, object]):
         """Sets the variables of this WorkflowStateUpdate.
 
 

src/conductor/client/http/models/workflow_task.py

@@ -1,6 +1,6 @@
 import pprint
 import re  # noqa: F401
-from typing import List
+from typing import List, Dict
 
 import six
 
@@ -124,7 +124,7 @@ def __init__(self, name=None, task_reference_name=None, description=None, input_
                  sub_workflow_param=None, join_on=None, sink=None, optional=None, task_definition : 'TaskDef' =None,
                  rate_limited=None, default_exclusive_join_task=None, async_complete=None, loop_condition=None,
                  loop_over=None, retry_count=None, evaluator_type=None, expression=None,
-                 workflow_task_type=None, on_state_change: dict[str, StateChangeConfig] = None,
+                 workflow_task_type=None, on_state_change: Dict[str, StateChangeConfig] = None,
                  cache_config: CacheConfig = None):  # noqa: E501
         """WorkflowTask - a model defined in Swagger"""  # noqa: E501
         self._name = None
@@ -850,7 +850,7 @@ def workflow_task_type(self, workflow_task_type):
         self._workflow_task_type = workflow_task_type
 
     @property
-    def on_state_change(self) -> dict[str, List[StateChangeEvent]]:
+    def on_state_change(self) -> Dict[str, List[StateChangeEvent]]:
         return self._on_state_change
 
     @on_state_change.setter

src/conductor/client/orkes/orkes_secret_client.py

@@ -1,4 +1,4 @@
-from typing import List
+from typing import List, Set
 
 from conductor.client.configuration.configuration import Configuration
 from conductor.client.orkes.models.metadata_tag import MetadataTag
@@ -16,7 +16,7 @@ def put_secret(self, key: str, value: str):
     def get_secret(self, key: str) -> str:
         return self.secretResourceApi.get_secret(key)
 
-    def list_all_secret_names(self) -> set[str]:
+    def list_all_secret_names(self) -> Set[str]:
         return set(self.secretResourceApi.list_all_secret_names())
 
     def list_secrets_that_user_can_grant_access_to(self) -> List[str]:

src/conductor/client/orkes/orkes_workflow_client.py

@@ -1,4 +1,4 @@
-from typing import Optional, List
+from typing import Optional, List, Dict
 
 from conductor.client.configuration.configuration import Configuration
 from conductor.client.http.models import SkipTaskRequest, WorkflowStatus, \
@@ -24,7 +24,7 @@ def __init__(
     def start_workflow_by_name(
             self,
             name: str,
-            input: dict[str, object],
+            input: Dict[str, object],
             version: Optional[int] = None,
             correlationId: Optional[str] = None,
             priority: Optional[int] = None,
@@ -130,7 +130,7 @@ def get_by_correlation_ids_in_batch(
             self,
             batch_request: CorrelationIdsSearchRequest,
             include_completed: bool = False,
-            include_tasks: bool = False) -> dict[str, List[Workflow]]:
+            include_tasks: bool = False) -> Dict[str, List[Workflow]]:
 
         """Given the list of correlation ids and list of workflow names, find and return workflows
         Returns a map with key as correlationId and value as a list of Workflows
@@ -150,7 +150,7 @@ def get_by_correlation_ids(
             correlation_ids: List[str],
             include_completed: bool = False,
             include_tasks: bool = False
-    ) -> dict[str, List[Workflow]]:
+    ) -> Dict[str, List[Workflow]]:
         """Lists workflows for the given correlation id list"""
         kwargs = {}
         if include_tasks:
@@ -167,7 +167,7 @@ def get_by_correlation_ids(
     def remove_workflow(self, workflow_id: str):
         self.workflowResourceApi.delete(workflow_id)
 
-    def update_variables(self, workflow_id: str, variables: dict[str, object] = {}) -> None:
+    def update_variables(self, workflow_id: str, variables: Dict[str, object] = {}) -> None:
         self.workflowResourceApi.update_workflow_state(variables, workflow_id)
 
     def update_state(self, workflow_id: str, update_requesst: WorkflowStateUpdate,