From a7314d2dd447c577a3d2bd63b745ee7bd3c20800 Mon Sep 17 00:00:00 2001
From: Dougal Matthews <dougal@redhat.com>
Date: Fri, 25 May 2018 09:40:29 +0100
Subject: [PATCH] Fix the call to start_workflow from events triggers
See Ida361a53ffdb5426a39d276d567391d25261fb7f for a similar fix.
Closes-Bug: #1772897
Depends-On: Ifac7617decc2990ff87b76d39bf0f72a61ff2b99
Change-Id: I06304e83e3bc2fd53110daf5c829824d3614b02e
---
mistral/event_engine/default_event_engine.py | 1 +
mistral/tests/unit/services/test_event_engine.py | 10 ++++++++--
2 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/mistral/event_engine/default_event_engine.py b/mistral/event_engine/default_event_engine.py
index 85e5ae568..0336623d7 100644
--- a/mistral/event_engine/default_event_engine.py
+++ b/mistral/event_engine/default_event_engine.py
@@ -255,6 +255,7 @@ class DefaultEventEngine(base.EventEngine):
self.engine_client.start_workflow(
t['workflow_id'],
t['workflow_namespace'],
+ None,
t['workflow_input'],
description=json.dumps(description),
**workflow_params
diff --git a/mistral/tests/unit/services/test_event_engine.py b/mistral/tests/unit/services/test_event_engine.py
index 3181639f7..ba1ebc72d 100644
--- a/mistral/tests/unit/services/test_event_engine.py
+++ b/mistral/tests/unit/services/test_event_engine.py
@@ -140,7 +140,10 @@ class EventEngineTest(base.DbTestCase):
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(
{
'service': 'fake_publisher',
@@ -181,7 +184,10 @@ class EventEngineTest(base.DbTestCase):
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(
{
'service': 'fake_publisher',