Fix for passing Integration tests

Author: orkes-harshil

src/conductor/client/http/api_client.py

@@ -272,6 +272,11 @@ def __deserialize(self, data, klass):
                 return [self.__deserialize(sub_data, sub_kls)
                         for sub_data in data]
 
+            if klass.startswith('set['):
+                sub_kls = re.match(r'set\[(.*)\]', klass).group(1)
+                return set(self.__deserialize(sub_data, sub_kls)
+                           for sub_data in data)
+
             if klass.startswith('dict('):
                 sub_kls = re.match(r'dict\(([^,]*), (.*)\)', klass).group(2)
                 return {k: self.__deserialize(v, sub_kls)

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

@@ -53,8 +53,11 @@ class SchemaDef(Auditable):
 
     discriminator: Any = field(default=None, init=False)
 
-    def __init__(self, name: str = None, version: int = 1, type: SchemaType = None, data: Dict[str, object] = None,
-                 external_ref: str = None):  # noqa: E501
+    def __init__(self, name: str = None, version: int = 1, type: SchemaType = None,
+                 data: Dict[str, object] = None, external_ref: str = None,
+                 owner_app: str = None, create_time: int = None, update_time: int = None,
+                 created_by: str = None, updated_by: str = None):  # noqa: E501
+        super().__init__()
         self._name = None
         self._version = None
         self._type = None
@@ -72,6 +75,18 @@ def __init__(self, name: str = None, version: int = 1, type: SchemaType = None,
         if external_ref is not None:
             self.external_ref = external_ref
 
+        # Set Auditable fields
+        if owner_app is not None:
+            self.owner_app = owner_app
+        if create_time is not None:
+            self.create_time = create_time
+        if update_time is not None:
+            self.update_time = update_time
+        if created_by is not None:
+            self.created_by = created_by
+        if updated_by is not None:
+            self.updated_by = updated_by
+
     def __post_init__(self, name_init: Optional[str], version_init: Optional[int], 
                      type_init: Optional[SchemaType], data_init: Optional[Dict[str, object]],
                      external_ref_init: Optional[str]):

src/conductor/client/workflow/executor/workflow_executor.py

@@ -1,7 +1,7 @@
 import uuid
-from typing import Any, Dict, List
+from typing import Any, Dict, List, Optional
 
-from typing_extensions import Self, Optional
+from typing_extensions import Self
 
 from conductor.client.configuration.configuration import Configuration
 from conductor.client.http.api.metadata_resource_api import MetadataResourceApi

tests/integration/client/orkes/test_orkes_clients.py

@@ -602,12 +602,44 @@ def __test_task_execution_lifecycle(self):
         assert queue_size == 0
 
     def __get_workflow_definition(self, path):
-        f = open(path, "r")
+        # Import os if not already imported
+        import os
+
+        # Get directory of current script
+        current_dir = os.path.dirname(os.path.abspath(__file__))
+
+        # Path to project root (need to go up several directories)
+        # From /tests/integration/client/orkes/ to project root
+        project_root = os.path.abspath(os.path.join(current_dir, '..', '..', '..', '..'))
+
+        # Construct path from project root
+        actual_path = os.path.join(project_root, path)
+
+        # For debugging
+        print(f"Attempting to open file at: {actual_path}")
+
+        f = open(actual_path, "r")
         workflowJSON = json.loads(f.read())
         workflowDef = self.api_client.deserialize_class(workflowJSON, "WorkflowDef")
         return workflowDef
 
     def __get_test_inputs(self, path):
-        f = open(path, "r")
+        # Import os if not already imported
+        import os
+
+        # Get directory of current script
+        current_dir = os.path.dirname(os.path.abspath(__file__))
+
+        # Path to project root (need to go up several directories)
+        # From /tests/integration/client/orkes/ to project root
+        project_root = os.path.abspath(os.path.join(current_dir, '..', '..', '..', '..'))
+
+        # Construct path from project root
+        actual_path = os.path.join(project_root, path)
+
+        # For debugging
+        print(f"Attempting to open file at: {actual_path}")
+
+        f = open(actual_path, "r")
         inputJSON = json.loads(f.read())
         return inputJSON