pojo sync poc

Author: orkes-harshil

python_sdk_server_pojo_mapping.json

@@ -0,0 +1,17 @@
+{
+  "serverPojoMappings": [
+    {
+      "server": {
+        "owner": "orkes-io",
+        "repo": "orkes-conductor",
+        "module": "server",
+        "className": "io.orkes.conductor.server.rest.model.requests.AuthorizationRequest"
+      },
+      "sdk": {
+        "owner": "conductor-sdk",
+        "repo": "conductor-python",
+        "className": "conductor.client.http.models.authorization_request.py"
+      }
+    }
+  ]
+}

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

@@ -18,28 +18,34 @@ class Action(object):
     """
     swagger_types = {
         'action': 'str',
-        'start_workflow': 'StartWorkflow',
+        'start_workflow': 'StartWorkflowRequest',
         'complete_task': 'TaskDetails',
         'fail_task': 'TaskDetails',
-        'expand_inline_json': 'bool'
+        'expand_inline_json': 'bool',
+        'terminate_workflow': 'TerminateWorkflow',
+        'update_workflow_variables': 'UpdateWorkflowVariables'
     }
 
     attribute_map = {
         'action': 'action',
         'start_workflow': 'start_workflow',
         'complete_task': 'complete_task',
         'fail_task': 'fail_task',
-        'expand_inline_json': 'expandInlineJSON'
+        'expand_inline_json': 'expandInlineJSON',
+        'terminate_workflow': 'terminate_workflow',
+        'update_workflow_variables': 'update_workflow_variables'
     }
 
     def __init__(self, action=None, start_workflow=None, complete_task=None, fail_task=None,
-                 expand_inline_json=None):  # noqa: E501
+                 expand_inline_json=None, terminate_workflow=None, update_workflow_variables=None):  # noqa: E501
         """Action - a model defined in Swagger"""  # noqa: E501
         self._action = None
         self._start_workflow = None
         self._complete_task = None
         self._fail_task = None
         self._expand_inline_json = None
+        self._terminate_workflow = None
+        self._update_workflow_variables = None
         self.discriminator = None
         if action is not None:
             self.action = action
@@ -51,6 +57,10 @@ def __init__(self, action=None, start_workflow=None, complete_task=None, fail_ta
             self.fail_task = fail_task
         if expand_inline_json is not None:
             self.expand_inline_json = expand_inline_json
+        if terminate_workflow is not None:
+            self.terminate_workflow = terminate_workflow
+        if update_workflow_variables is not None:
+            self.update_workflow_variables = update_workflow_variables
 
     @property
     def action(self):
@@ -70,7 +80,7 @@ def action(self, action):
         :param action: The action of this Action.  # noqa: E501
         :type: str
         """
-        allowed_values = ["start_workflow", "complete_task", "fail_task"]  # noqa: E501
+        allowed_values = ["start_workflow", "complete_task", "fail_task", "terminate_workflow", "update_workflow_variables"]  # noqa: E501
         if action not in allowed_values:
             raise ValueError(
                 "Invalid value for `action` ({0}), must be one of {1}"  # noqa: E501
@@ -85,7 +95,7 @@ def start_workflow(self):
 
 
         :return: The start_workflow of this Action.  # noqa: E501
-        :rtype: StartWorkflow
+        :rtype: StartWorkflowRequest
         """
         return self._start_workflow
 
@@ -95,7 +105,7 @@ def start_workflow(self, start_workflow):
 
 
         :param start_workflow: The start_workflow of this Action.  # noqa: E501
-        :type: StartWorkflow
+        :type: StartWorkflowRequest
         """
 
         self._start_workflow = start_workflow
@@ -163,6 +173,48 @@ def expand_inline_json(self, expand_inline_json):
 
         self._expand_inline_json = expand_inline_json
 
+    @property
+    def terminate_workflow(self):
+        """Gets the terminate_workflow of this Action.  # noqa: E501
+
+
+        :return: The terminate_workflow of this Action.  # noqa: E501
+        :rtype: TerminateWorkflow
+        """
+        return self._terminate_workflow
+
+    @terminate_workflow.setter
+    def terminate_workflow(self, terminate_workflow):
+        """Sets the terminate_workflow of this Action.
+
+
+        :param terminate_workflow: The terminate_workflow of this Action.  # noqa: E501
+        :type: TerminateWorkflow
+        """
+
+        self._terminate_workflow = terminate_workflow
+
+    @property
+    def update_workflow_variables(self):
+        """Gets the update_workflow_variables of this Action.  # noqa: E501
+
+
+        :return: The update_workflow_variables of this Action.  # noqa: E501
+        :rtype: UpdateWorkflowVariables
+        """
+        return self._update_workflow_variables
+
+    @update_workflow_variables.setter
+    def update_workflow_variables(self, update_workflow_variables):
+        """Sets the update_workflow_variables of this Action.
+
+
+        :param update_workflow_variables: The update_workflow_variables of this Action.  # noqa: E501
+        :type: UpdateWorkflowVariables
+        """
+
+        self._update_workflow_variables = update_workflow_variables
+
     def to_dict(self):
         """Returns the model properties as a dict"""
         result = {}
@@ -207,4 +259,4 @@ def __eq__(self, other):
 
     def __ne__(self, other):
         """Returns true if both objects are not equal"""
-        return not self == other
+        return not self == other

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

@@ -18,18 +18,21 @@ class BulkResponse(object):
     """
     swagger_types = {
         'bulk_error_results': 'dict(str, str)',
-        'bulk_successful_results': 'list[str]'
+        'bulk_successful_results': 'list[str]',
+        'message': 'str'
     }
 
     attribute_map = {
         'bulk_error_results': 'bulkErrorResults',
-        'bulk_successful_results': 'bulkSuccessfulResults'
+        'bulk_successful_results': 'bulkSuccessfulResults',
+        'message': 'message'
     }
 
     def __init__(self, bulk_error_results=None, bulk_successful_results=None):  # noqa: E501
         """BulkResponse - a model defined in Swagger"""  # noqa: E501
         self._bulk_error_results = None
         self._bulk_successful_results = None
+        self._message = "Bulk Request has been processed."
         self.discriminator = None
         if bulk_error_results is not None:
             self.bulk_error_results = bulk_error_results
@@ -40,6 +43,7 @@ def __init__(self, bulk_error_results=None, bulk_successful_results=None):  # no
     def bulk_error_results(self):
         """Gets the bulk_error_results of this BulkResponse.  # noqa: E501
 
+        Key - entityId Value - error message processing this entity
 
         :return: The bulk_error_results of this BulkResponse.  # noqa: E501
         :rtype: dict(str, str)
@@ -50,6 +54,7 @@ def bulk_error_results(self):
     def bulk_error_results(self, bulk_error_results):
         """Sets the bulk_error_results of this BulkResponse.
 
+        Key - entityId Value - error message processing this entity
 
         :param bulk_error_results: The bulk_error_results of this BulkResponse.  # noqa: E501
         :type: dict(str, str)
@@ -78,6 +83,35 @@ def bulk_successful_results(self, bulk_successful_results):
 
         self._bulk_successful_results = bulk_successful_results
 
+    @property
+    def message(self):
+        """Gets the message of this BulkResponse.  # noqa: E501
+
+
+        :return: The message of this BulkResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._message
+
+    def append_success_response(self, result):
+        """Appends a successful result to bulk_successful_results.  # noqa: E501
+
+        :param result: The result to append to bulk_successful_results
+        """
+        if self._bulk_successful_results is None:
+            self._bulk_successful_results = []
+        self._bulk_successful_results.append(result)
+
+    def append_failed_response(self, id, error_message):
+        """Appends a failed result to bulk_error_results.  # noqa: E501
+
+        :param id: The entity ID that failed
+        :param error_message: The error message for the failed entity
+        """
+        if self._bulk_error_results is None:
+            self._bulk_error_results = {}
+        self._bulk_error_results[id] = error_message
+
     def to_dict(self):
         """Returns the model properties as a dict"""
         result = {}
@@ -122,4 +156,4 @@ def __eq__(self, other):
 
     def __ne__(self, other):
         """Returns true if both objects are not equal"""
-        return not self == other
+        return not self == other

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

@@ -2,6 +2,7 @@
 import re  # noqa: F401
 
 import six
+from deprecated import deprecated
 
 
 class ConductorApplication(object):
@@ -19,27 +20,42 @@ class ConductorApplication(object):
     swagger_types = {
         'id': 'str',
         'name': 'str',
-        'created_by': 'str'
+        'created_by': 'str',
+        'create_time': 'int',
+        'update_time': 'int',
+        'updated_by': 'str'
     }
 
     attribute_map = {
         'id': 'id',
         'name': 'name',
-        'created_by': 'createdBy'
+        'created_by': 'createdBy',
+        'create_time': 'createTime',
+        'update_time': 'updateTime',
+        'updated_by': 'updatedBy'
     }
 
-    def __init__(self, id=None, name=None, created_by=None):  # noqa: E501
+    def __init__(self, id=None, name=None, created_by=None, create_time=None, update_time=None, updated_by=None):  # noqa: E501
         """ConductorApplication - a model defined in Swagger"""  # noqa: E501
         self._id = None
         self._name = None
         self._created_by = None
+        self._create_time = None
+        self._update_time = None
+        self._updated_by = None
         self.discriminator = None
         if id is not None:
             self.id = id
         if name is not None:
             self.name = name
         if created_by is not None:
             self.created_by = created_by
+        if create_time is not None:
+            self.create_time = create_time
+        if update_time is not None:
+            self.update_time = update_time
+        if updated_by is not None:
+            self.updated_by = updated_by
 
     @property
     def id(self):
@@ -104,6 +120,69 @@ def created_by(self, created_by):
 
         self._created_by = created_by
 
+    @property
+    def create_time(self):
+        """Gets the create_time of this ConductorApplication.  # noqa: E501
+
+
+        :return: The create_time of this ConductorApplication.  # noqa: E501
+        :rtype: int
+        """
+        return self._create_time
+
+    @create_time.setter
+    def create_time(self, create_time):
+        """Sets the create_time of this ConductorApplication.
+
+
+        :param create_time: The create_time of this ConductorApplication.  # noqa: E501
+        :type: int
+        """
+
+        self._create_time = create_time
+
+    @property
+    def update_time(self):
+        """Gets the update_time of this ConductorApplication.  # noqa: E501
+
+
+        :return: The update_time of this ConductorApplication.  # noqa: E501
+        :rtype: int
+        """
+        return self._update_time
+
+    @update_time.setter
+    def update_time(self, update_time):
+        """Sets the update_time of this ConductorApplication.
+
+
+        :param update_time: The update_time of this ConductorApplication.  # noqa: E501
+        :type: int
+        """
+
+        self._update_time = update_time
+
+    @property
+    def updated_by(self):
+        """Gets the updated_by of this ConductorApplication.  # noqa: E501
+
+
+        :return: The updated_by of this ConductorApplication.  # noqa: E501
+        :rtype: str
+        """
+        return self._updated_by
+
+    @updated_by.setter
+    def updated_by(self, updated_by):
+        """Sets the updated_by of this ConductorApplication.
+
+
+        :param updated_by: The updated_by of this ConductorApplication.  # noqa: E501
+        :type: str
+        """
+
+        self._updated_by = updated_by
+
     def to_dict(self):
         """Returns the model properties as a dict"""
         result = {}
@@ -148,4 +227,4 @@ def __eq__(self, other):
 
     def __ne__(self, other):
         """Returns true if both objects are not equal"""
-        return not self == other
+        return not self == other

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

@@ -1,5 +1,6 @@
 import pprint
 import re  # noqa: F401
+from deprecated import deprecated
 
 import six
 
@@ -173,6 +174,7 @@ def uuid(self, uuid):
         self._uuid = uuid
 
     @property
+    @deprecated
     def application_user(self):
         """Gets the application_user of this ConductorUser.  # noqa: E501
 
@@ -183,6 +185,7 @@ def application_user(self):
         return self._application_user
 
     @application_user.setter
+    @deprecated
     def application_user(self, application_user):
         """Sets the application_user of this ConductorUser.
 
@@ -279,4 +282,4 @@ def __eq__(self, other):
 
     def __ne__(self, other):
         """Returns true if both objects are not equal"""
-        return not self == other
+        return not self == other