openstack/mistral
Code Issues Proposed changes

Merge "Add descriptions for on_task_state_change parameters."

Browse Source
This commit is contained in:
Jenkins 2016-12-05 15:58:13 +00:00 committed by Gerrit Code Review
commit 3daa283303
2 changed files with 0 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mistral/engine/engine_server.py
View File

@ -132,10 +132,6 @@ class EngineServer(service_base.MistralService):
**params **params
) )
def on_task_state_change(self, rpc_ctx, task_ex_id, state,
state_info=None):
return self.engine.on_task_state_change(task_ex_id, state, state_info)
def on_action_complete(self, rpc_ctx, action_ex_id, result_data, def on_action_complete(self, rpc_ctx, action_ex_id, result_data,
result_error, wf_action): result_error, wf_action):
"""Receives RPC calls to communicate action result to engine. """Receives RPC calls to communicate action result to engine.

9
mistral/engine/rpc_backend/rpc.py
View File

@ -198,15 +198,6 @@ class EngineClient(base.Engine):
params=params params=params
) )
def on_task_state_change(self, task_ex_id, state, state_info=None):
return self._client.sync_call(
auth_ctx.ctx(),
'on_task_state_change',
task_ex_id=task_ex_id,
state=state,
state_info=state_info
)
@wrap_messaging_exception @wrap_messaging_exception
def on_action_complete(self, action_ex_id, result, wf_action=False, def on_action_complete(self, action_ex_id, result, wf_action=False,
async=False): async=False):