diff --git a/mistral/engine1/commands.py b/mistral/engine1/commands.py index 882d1e86f..f49c667f4 100644 --- a/mistral/engine1/commands.py +++ b/mistral/engine1/commands.py @@ -100,7 +100,8 @@ class RunTask(EngineCommand): 'input': None, 'in_context': None, 'output': None, - 'runtime_context': None + 'runtime_context': None, + 'wf_name': exec_db.wf_name }) def _run_task(self): diff --git a/mistral/tests/unit/engine1/test_default_engine.py b/mistral/tests/unit/engine1/test_default_engine.py index cdbffce84..53be3775c 100644 --- a/mistral/tests/unit/engine1/test_default_engine.py +++ b/mistral/tests/unit/engine1/test_default_engine.py @@ -93,6 +93,7 @@ class DefaultEngineTest(base.DbTestCase): task_db = exec_db.tasks[0] + self.assertEqual('wb.wf1', task_db.wf_name) self.assertEqual('task1', task_db.name) self.assertEqual(states.RUNNING, task_db.state) self.assertIsNotNone(task_db.spec)