contrib/runners/mistral_v2/query/mistral_v2.py
def _get_workflow_result(self, exec_id):
        """
        Returns the workflow status and output. Mistral workflow status will be converted
        to st2 action status.
        :param exec_id: Mistral execution ID
        :type exec_id: ``str``
        :rtype: (``str``, ``dict``)
        """
        try:
            jitter = random.uniform(0, self._jitter)
            eventlet.sleep(jitter)
            execution = self._client.executions.get(exec_id)
        except mistralclient_base.APIException as mistral_exc:
            if 'not found' in mistral_exc.message:
                raise exceptions.ReferenceNotFoundError(mistral_exc.message)
            raise mistral_exc

        result = jsonify.try_loads(execution.output) if execution.state in DONE_STATES else {}

        result['extra'] = {
            'state': execution.state,
            'state_info': execution.state_info
        }

        return result

        Returns the workflow status and output. Mistral workflow status will be converted
        to st2 action status.
        :param exec_id: Mistral execution ID
        :type exec_id: ``str``
        :rtype: (``str``, ``dict``)
        
Returns the workflow status and output. Mistral workflow status will be converted
to st2 action status.
Returns the workflow status and output . Mistral workflow status will be converted to st2 action status .
def _get_workflow_result(self, exec_id):
        try:
            jitter = random.uniform(0, self._jitter)
            eventlet.sleep(jitter)
            execution = self._client.executions.get(exec_id)
        except mistralclient_base.APIException as mistral_exc:
            if 'not found' in mistral_exc.message:
                raise exceptions.ReferenceNotFoundError(mistral_exc.message)
            raise mistral_exc
        result = jsonify.try_loads(execution.output) if execution.state in DONE_STATES else {}
        result['extra'] = {
            'state': execution.state,
            'state_info': execution.state_info
        }
        return result
def _get_workflow_result ( self , exec_id ) : try : jitter = random . uniform ( 0 , self . _jitter ) eventlet . sleep ( jitter ) execution = self . _client . executions . get ( exec_id ) except mistralclient_base . APIException as mistral_exc : if 'not found' in mistral_exc . message : raise exceptions . ReferenceNotFoundError ( mistral_exc . message ) raise mistral_exc result = jsonify . try_loads ( execution . output ) if execution . state in DONE_STATES else { } result [ 'extra' ] = { 'state' : execution . state , 'state_info' : execution . state_info } return result
Returns the workflow status and output.
Returns the workflow status and output .
"""
        Returns the workflow status and output. Mistral workflow status will be converted
        to st2 action status.
        :param exec_id: Mistral execution ID
        :type exec_id: ``str``
        :rtype: (``str``, ``dict``)
        """
None
(``str``, ``dict``)
self
exec_id
Mistral execution ID
Mistral execution ID