openstack/mistral
Code Issues Proposed changes

Merge "Fix the call to start_workflow from events triggers"

Browse Source
This commit is contained in:
Zuul 2018-06-07 18:59:28 +00:00 committed by Gerrit Code Review
commit 13b2b0fbaf
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
mistral/event_engine/default_event_engine.py
View File

@ -255,6 +255,7 @@ class DefaultEventEngine(base.EventEngine):
self.engine_client.start_workflow( self.engine_client.start_workflow(
t['workflow_id'], t['workflow_id'],
t['workflow_namespace'], t['workflow_namespace'],
None,
t['workflow_input'], t['workflow_input'],
description=json.dumps(description), description=json.dumps(description),
**workflow_params **workflow_params

10
mistral/tests/unit/services/test_event_engine.py
View File

@ -140,7 +140,10 @@ class EventEngineTest(base.DbTestCase):
args, kwargs = client_mock.start_workflow.call_args args, kwargs = client_mock.start_workflow.call_args
self.assertEqual((EVENT_TRIGGER['workflow_id'], '', {}), args) self.assertEqual(
(EVENT_TRIGGER['workflow_id'], '', None, {}),
args
)
self.assertDictEqual( self.assertDictEqual(
{ {
'service': 'fake_publisher', 'service': 'fake_publisher',
@ -181,7 +184,10 @@ class EventEngineTest(base.DbTestCase):
args, kwargs = client_mock.start_workflow.call_args args, kwargs = client_mock.start_workflow.call_args
self.assertEqual((EVENT_TRIGGER['workflow_id'], '', {}), args) self.assertEqual(
(EVENT_TRIGGER['workflow_id'], '', None, {}),
args
)
self.assertDictEqual( self.assertDictEqual(
{ {
'service': 'fake_publisher', 'service': 'fake_publisher',