Added WF Execute with sync and durable consistency

Author: Shailesh Jagannath Padave

src/conductor/client/http/api/service_registry_resource_api.py

@@ -214,7 +214,9 @@ def execute_workflow(self, body, request_id, name, version, **kwargs):  # noqa:
         :param int version: (required)
         :param str wait_until_task_ref:
         :param int wait_for_seconds:
-        :return: WorkflowRun
+        :param str consistency:
+        :param str return_strategy:
+        :return: SignalResponse
                  If the method is called asynchronously,
                  returns the request thread.
         """
@@ -240,12 +242,14 @@ def execute_workflow_with_http_info(self, body, request_id, name, version, **kwa
         :param int version: (required)
         :param str wait_until_task_ref:
         :param int wait_for_seconds:
-        :return: WorkflowRun
+        :param str consistency:
+        :param str return_strategy:
+        :return: SignalResponse
                  If the method is called asynchronously,
                  returns the request thread.
         """
 
-        all_params = ['body', 'request_id', 'name', 'version', 'wait_until_task_ref', 'wait_for_seconds']  # noqa: E501
+        all_params = ['body', 'name', 'version', 'request_id', 'wait_until_task_ref', 'wait_for_seconds', 'consistency', 'return_strategy']  # noqa: E501
         all_params.append('async_req')
         all_params.append('_return_http_data_only')
         all_params.append('_preload_content')
@@ -293,6 +297,10 @@ def execute_workflow_with_http_info(self, body, request_id, name, version, **kwa
             query_params.append(('waitUntilTaskRef', params['wait_until_task_ref']))  # noqa: E501
         if 'wait_for_seconds' in params:
             query_params.append(('waitForSeconds', params['wait_for_seconds']))  # noqa: E501
+        if 'consistency' in params:
+            query_params.append(('consistency', params['consistency']))  # noqa: E501
+        if 'return_strategy' in params:
+            query_params.append(('returnStrategy', params['return_strategy']))  # noqa: E501
 
         header_params = {}
 
@@ -321,7 +329,7 @@ def execute_workflow_with_http_info(self, body, request_id, name, version, **kwa
             body=body_params,
             post_params=form_params,
             files=local_var_files,
-            response_type='WorkflowRun',  # noqa: E501
+            response_type='SignalResponse',  # noqa: E501
             auth_settings=auth_settings,
             async_req=params.get('async_req'),
             _return_http_data_only=params.get('_return_http_data_only'),

src/conductor/client/http/api/workflow_resource_api.py

@@ -0,0 +1,298 @@
+# coding: utf-8
+
+"""
+    Orkes Conductor API Server
+
+    Orkes Conductor API Server  # noqa: E501
+
+    OpenAPI spec version: v2
+
+    Generated by: https://github.com/swagger-api/swagger-codegen.git
+"""
+
+import pprint
+import re  # noqa: F401
+
+import six
+
+class SignalResponse(object):
+    """NOTE: This class is auto generated by the swagger code generator program.
+
+    Do not edit the class manually.
+    """
+    """
+    Attributes:
+      swagger_types (dict): The key is attribute name
+                            and the value is attribute type.
+      attribute_map (dict): The key is attribute name
+                            and the value is json key in definition.
+    """
+    swagger_types = {
+        'correlation_id': 'str',
+        'input': 'dict(str, object)',
+        'output': 'dict(str, object)',
+        'request_id': 'str',
+        'response_type': 'str',
+        'target_workflow_id': 'str',
+        'target_workflow_status': 'str',
+        'workflow_id': 'str'
+    }
+
+    attribute_map = {
+        'correlation_id': 'correlationId',
+        'input': 'input',
+        'output': 'output',
+        'request_id': 'requestId',
+        'response_type': 'responseType',
+        'target_workflow_id': 'targetWorkflowId',
+        'target_workflow_status': 'targetWorkflowStatus',
+        'workflow_id': 'workflowId'
+    }
+
+    def __init__(self, correlation_id=None, input=None, output=None, request_id=None, response_type=None, target_workflow_id=None, target_workflow_status=None, workflow_id=None):  # noqa: E501
+        """SignalResponse - a model defined in Swagger"""  # noqa: E501
+        self._correlation_id = None
+        self._input = None
+        self._output = None
+        self._request_id = None
+        self._response_type = None
+        self._target_workflow_id = None
+        self._target_workflow_status = None
+        self._workflow_id = None
+        self.discriminator = None
+        if correlation_id is not None:
+            self.correlation_id = correlation_id
+        if input is not None:
+            self.input = input
+        if output is not None:
+            self.output = output
+        if request_id is not None:
+            self.request_id = request_id
+        if response_type is not None:
+            self.response_type = response_type
+        if target_workflow_id is not None:
+            self.target_workflow_id = target_workflow_id
+        if target_workflow_status is not None:
+            self.target_workflow_status = target_workflow_status
+        if workflow_id is not None:
+            self.workflow_id = workflow_id
+
+    @property
+    def correlation_id(self):
+        """Gets the correlation_id of this SignalResponse.  # noqa: E501
+
+
+        :return: The correlation_id of this SignalResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._correlation_id
+
+    @correlation_id.setter
+    def correlation_id(self, correlation_id):
+        """Sets the correlation_id of this SignalResponse.
+
+
+        :param correlation_id: The correlation_id of this SignalResponse.  # noqa: E501
+        :type: str
+        """
+
+        self._correlation_id = correlation_id
+
+    @property
+    def input(self):
+        """Gets the input of this SignalResponse.  # noqa: E501
+
+
+        :return: The input of this SignalResponse.  # noqa: E501
+        :rtype: dict(str, object)
+        """
+        return self._input
+
+    @input.setter
+    def input(self, input):
+        """Sets the input of this SignalResponse.
+
+
+        :param input: The input of this SignalResponse.  # noqa: E501
+        :type: dict(str, object)
+        """
+
+        self._input = input
+
+    @property
+    def output(self):
+        """Gets the output of this SignalResponse.  # noqa: E501
+
+
+        :return: The output of this SignalResponse.  # noqa: E501
+        :rtype: dict(str, object)
+        """
+        return self._output
+
+    @output.setter
+    def output(self, output):
+        """Sets the output of this SignalResponse.
+
+
+        :param output: The output of this SignalResponse.  # noqa: E501
+        :type: dict(str, object)
+        """
+
+        self._output = output
+
+    @property
+    def request_id(self):
+        """Gets the request_id of this SignalResponse.  # noqa: E501
+
+
+        :return: The request_id of this SignalResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._request_id
+
+    @request_id.setter
+    def request_id(self, request_id):
+        """Sets the request_id of this SignalResponse.
+
+
+        :param request_id: The request_id of this SignalResponse.  # noqa: E501
+        :type: str
+        """
+
+        self._request_id = request_id
+
+    @property
+    def response_type(self):
+        """Gets the response_type of this SignalResponse.  # noqa: E501
+
+
+        :return: The response_type of this SignalResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._response_type
+
+    @response_type.setter
+    def response_type(self, response_type):
+        """Sets the response_type of this SignalResponse.
+
+
+        :param response_type: The response_type of this SignalResponse.  # noqa: E501
+        :type: str
+        """
+        allowed_values = ["TARGET_WORKFLOW", "BLOCKING_WORKFLOW", "BLOCKING_TASK", "BLOCKING_TASK_INPUT"]  # noqa: E501
+        if response_type not in allowed_values:
+            raise ValueError(
+                "Invalid value for `response_type` ({0}), must be one of {1}"  # noqa: E501
+                .format(response_type, allowed_values)
+            )
+
+        self._response_type = response_type
+
+    @property
+    def target_workflow_id(self):
+        """Gets the target_workflow_id of this SignalResponse.  # noqa: E501
+
+
+        :return: The target_workflow_id of this SignalResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._target_workflow_id
+
+    @target_workflow_id.setter
+    def target_workflow_id(self, target_workflow_id):
+        """Sets the target_workflow_id of this SignalResponse.
+
+
+        :param target_workflow_id: The target_workflow_id of this SignalResponse.  # noqa: E501
+        :type: str
+        """
+
+        self._target_workflow_id = target_workflow_id
+
+    @property
+    def target_workflow_status(self):
+        """Gets the target_workflow_status of this SignalResponse.  # noqa: E501
+
+
+        :return: The target_workflow_status of this SignalResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._target_workflow_status
+
+    @target_workflow_status.setter
+    def target_workflow_status(self, target_workflow_status):
+        """Sets the target_workflow_status of this SignalResponse.
+
+
+        :param target_workflow_status: The target_workflow_status of this SignalResponse.  # noqa: E501
+        :type: str
+        """
+
+        self._target_workflow_status = target_workflow_status
+
+    @property
+    def workflow_id(self):
+        """Gets the workflow_id of this SignalResponse.  # noqa: E501
+
+
+        :return: The workflow_id of this SignalResponse.  # noqa: E501
+        :rtype: str
+        """
+        return self._workflow_id
+
+    @workflow_id.setter
+    def workflow_id(self, workflow_id):
+        """Sets the workflow_id of this SignalResponse.
+
+
+        :param workflow_id: The workflow_id of this SignalResponse.  # noqa: E501
+        :type: str
+        """
+
+        self._workflow_id = workflow_id
+
+    def to_dict(self):
+        """Returns the model properties as a dict"""
+        result = {}
+
+        for attr, _ in six.iteritems(self.swagger_types):
+            value = getattr(self, attr)
+            if isinstance(value, list):
+                result[attr] = list(map(
+                    lambda x: x.to_dict() if hasattr(x, "to_dict") else x,
+                    value
+                ))
+            elif hasattr(value, "to_dict"):
+                result[attr] = value.to_dict()
+            elif isinstance(value, dict):
+                result[attr] = dict(map(
+                    lambda item: (item[0], item[1].to_dict())
+                    if hasattr(item[1], "to_dict") else item,
+                    value.items()
+                ))
+            else:
+                result[attr] = value
+        if issubclass(SignalResponse, dict):
+            for key, value in self.items():
+                result[key] = value
+
+        return result
+
+    def to_str(self):
+        """Returns the string representation of the model"""
+        return pprint.pformat(self.to_dict())
+
+    def __repr__(self):
+        """For `print` and `pprint`"""
+        return self.to_str()
+
+    def __eq__(self, other):
+        """Returns true if both objects are equal"""
+        if not isinstance(other, SignalResponse):
+            return False
+
+        return self.__dict__ == other.__dict__
+
+    def __ne__(self, other):
+        """Returns true if both objects are not equal"""
+        return not self == other