Merge pull request #288 from conductor-sdk/auto-serder-test

serialisation deserialisation tests + fixes in model files

Author: orkes-harshil

src/conductor/client/configuration/configuration.py

@@ -29,7 +29,7 @@ def __init__(
         self.temp_folder_path = None
         self.__ui_host = os.getenv('CONDUCTOR_UI_SERVER_URL')
         if self.__ui_host is None:
-            self.__ui_host = self.host.replace('8080/api', '5000')
+            self.__ui_host = self.host.replace('8080/api', '5001')
 
         if authentication_settings is not None:
             self.authentication_settings = authentication_settings

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

@@ -37,6 +37,7 @@
 from conductor.client.http.models.task_details import TaskDetails
 from conductor.client.http.models.task_exec_log import TaskExecLog
 from conductor.client.http.models.task_result import TaskResult
+from conductor.client.http.models.task_result_status import TaskResultStatus
 from conductor.client.http.models.task_summary import TaskSummary
 from conductor.client.http.models.token import Token
 from conductor.client.http.models.upsert_group_request import UpsertGroupRequest
@@ -47,6 +48,7 @@
 from conductor.client.http.models.workflow_schedule import WorkflowSchedule
 from conductor.client.http.models.workflow_schedule_execution_model import WorkflowScheduleExecutionModel
 from conductor.client.http.models.workflow_status import WorkflowStatus
+from conductor.client.http.models.workflow_state_update import WorkflowStateUpdate
 from conductor.client.http.models.workflow_summary import WorkflowSummary
 from conductor.client.http.models.workflow_tag import WorkflowTag
 from conductor.client.http.models.integration import Integration

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

@@ -19,13 +19,13 @@ class CreateOrUpdateApplicationRequest:
       attribute_map (dict): The key is attribute name
                             and the value is json key in definition.
     """
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types = {
         'name': 'str'
-    })
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         'name': 'name'
-    })
+    }
 
     name: InitVar[Optional[str]] = None
     _name: Optional[str] = field(default=None, init=False)

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

@@ -22,15 +22,15 @@ class GenerateTokenRequest:
     key_secret: Optional[str] = field(default=None)
 
     # Class variables
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types = {
         'key_id': 'str',
         'key_secret': 'str'
-    })
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         'key_id': 'keyId',
         'key_secret': 'keySecret'
-    })
+    }
 
     def __init__(self, key_id=None, key_secret=None):  # noqa: E501
         """GenerateTokenRequest - a model defined in Swagger"""  # noqa: E501

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

@@ -33,7 +33,7 @@ class Integration:
     _updated_on: Optional[int] = field(default=None, init=False)
     _apis: Optional[List['IntegrationApi']] = field(default=None, init=False)
 
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types = {
         'category': 'str',
         'configuration': 'dict(str, object)',
         'created_by': 'str',
@@ -47,9 +47,9 @@ class Integration:
         'updated_by': 'str',
         'updated_on': 'int',
         'apis': 'list[IntegrationApi]'
-    }, init=False)
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         'category': 'category',
         'configuration': 'configuration',
         'created_by': 'createdBy',
@@ -63,7 +63,7 @@ class Integration:
         'updated_by': 'updatedBy',
         'updated_on': 'updatedOn',
         'apis': 'apis'
-    }, init=False)
+    }
 
     def __init__(self, category=None, configuration=None, created_by=None, created_on=None, description=None,
                  enabled=None, models_count=None, name=None, tags=None, type=None, updated_by=None,

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

@@ -26,7 +26,7 @@ class IntegrationApi:
     _updated_by: Optional[str] = field(default=None, repr=False)
     _updated_on: Optional[int] = field(default=None, repr=False)
 
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types = {
         'api': 'str',
         'configuration': 'dict(str, object)',
         'created_by': 'str',
@@ -37,9 +37,9 @@ class IntegrationApi:
         'tags': 'list[TagObject]',
         'updated_by': 'str',
         'updated_on': 'int'
-    }, repr=False)
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         'api': 'api',
         'configuration': 'configuration',
         'created_by': 'createdBy',
@@ -50,7 +50,7 @@ class IntegrationApi:
         'tags': 'tags',
         'updated_by': 'updatedBy',
         'updated_on': 'updatedOn'
-    }, repr=False)
+    }
 
     discriminator: Optional[str] = field(default=None, repr=False)
 

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

@@ -17,13 +17,13 @@ class Permission:
       attribute_map (dict): The key is attribute name
                             and the value is json key in definition.
     """
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types = {
         'name': 'str'
-    })
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         'name': 'name'
-    })
+    }
 
     _name: Optional[str] = field(default=None, init=False)
 

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

@@ -19,19 +19,19 @@ class PollData:
       attribute_map (dict): The key is attribute name
                             and the value is json key in definition.
     """
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types = {
         'queue_name': 'str',
         'domain': 'str',
         'worker_id': 'str',
         'last_poll_time': 'int'
-    })
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         'queue_name': 'queueName',
         'domain': 'domain',
         'worker_id': 'workerId',
         'last_poll_time': 'lastPollTime'
-    })
+    }
 
     queue_name: Optional[str] = field(default=None)
     domain: Optional[str] = field(default=None)

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

@@ -37,25 +37,25 @@ class PromptTemplateTestRequest:
     _top_p: Optional[float] = field(init=False, repr=False, default=None)
 
     # Class variables
-    swagger_types: Dict[str, str] = field(init=False, repr=False, default_factory=lambda: {
+    swagger_types = {
         'llm_provider': 'str',
         'model': 'str',
         'prompt': 'str',
         'prompt_variables': 'dict(str, object)',
         'stop_words': 'list[str]',
         'temperature': 'float',
         'top_p': 'float'
-    })
+    }
 
-    attribute_map: Dict[str, str] = field(init=False, repr=False, default_factory=lambda: {
+    attribute_map = {
         'llm_provider': 'llmProvider',
         'model': 'model',
         'prompt': 'prompt',
         'prompt_variables': 'promptVariables',
         'stop_words': 'stopWords',
         'temperature': 'temperature',
         'top_p': 'topP'
-    })
+    }
 
     discriminator: None = field(init=False, repr=False, default=None)
 

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

@@ -26,21 +26,21 @@ class RerunWorkflowRequest:
     correlation_id: InitVar[Optional[str]] = None
 
     # Class properties for swagger documentation
-    swagger_types: Dict[str, str] = field(default_factory=lambda: {
+    swagger_types =  {
         're_run_from_workflow_id': 'str',
         'workflow_input': 'dict(str, object)',
         're_run_from_task_id': 'str',
         'task_input': 'dict(str, object)',
         'correlation_id': 'str'
-    }, init=False)
+    }
 
-    attribute_map: Dict[str, str] = field(default_factory=lambda: {
+    attribute_map = {
         're_run_from_workflow_id': 'reRunFromWorkflowId',
         'workflow_input': 'workflowInput',
         're_run_from_task_id': 'reRunFromTaskId',
         'task_input': 'taskInput',
         'correlation_id': 'correlationId'
-    }, init=False)
+    }
 
     def __post_init__(self, re_run_from_workflow_id, workflow_input, re_run_from_task_id, task_input, correlation_id):
         """Initialize attributes after @dataclass initialization"""