Fix TaskFlow loader to honor engine configuration
The TaskFlow flow loader was not honoring the TaskFlow engine configured in the octavia.conf. This patch corrects that behavior so the "parallel" engine can be used. Change-Id: I4e9a21f1c58cbf65f4247fe3e2255dc614080bc7
This commit is contained in:
parent
a05d8aa763
commit
4c11b69685
@ -36,7 +36,7 @@ class BaseTaskFlowEngine(object):
|
||||
def _taskflow_load(self, flow, **kwargs):
|
||||
eng = tf_engines.load(
|
||||
flow,
|
||||
engine_conf=CONF.task_flow.engine,
|
||||
engine=CONF.task_flow.engine,
|
||||
executor=self.executor,
|
||||
never_resolve=CONF.task_flow.disable_revert,
|
||||
**kwargs)
|
||||
|
@ -60,7 +60,7 @@ class TestBaseTaskFlowEngine(base.TestCase):
|
||||
|
||||
tf_engines.load.assert_called_once_with(
|
||||
'TEST',
|
||||
engine_conf='TESTENGINE',
|
||||
engine='TESTENGINE',
|
||||
executor='TESTEXECUTOR',
|
||||
never_resolve=True)
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user