diff --git a/octavia/common/base_taskflow.py b/octavia/common/base_taskflow.py
index 711adb9190..29a5062215 100644
--- a/octavia/common/base_taskflow.py
+++ b/octavia/common/base_taskflow.py
@@ -166,7 +166,10 @@ class TaskFlowServiceController(object):
                         'redis_taskflow_driver'):
                     conductor = RedisDynamicLoggingConductor(
                         name, board, persistence=persistence,
-                        engine=CONF.task_flow.engine)
+                        engine=CONF.task_flow.engine,
+                        engine_options={
+                            'max_workers': CONF.task_flow.max_workers
+                        })
                     board.claim = functools.partial(
                         board.claim,
                         expiry=CONF.task_flow.jobboard_expiration_time)
diff --git a/octavia/tests/unit/common/test_base_taskflow.py b/octavia/tests/unit/common/test_base_taskflow.py
index dc18bc14a0..794128769b 100644
--- a/octavia/tests/unit/common/test_base_taskflow.py
+++ b/octavia/tests/unit/common/test_base_taskflow.py
@@ -75,6 +75,7 @@ class TestTaskFlowServiceController(base.TestCase):
     def setUp(self):
         self.conf = oslo_fixture.Config(cfg.CONF)
         self.conf.config(group="task_flow", engine='parallel')
+        self.conf.config(group="task_flow", max_workers=MAX_WORKERS)
         self.driver_mock = mock.MagicMock()
         self.persistence_mock = mock.MagicMock()
         self.jobboard_mock = mock.MagicMock()
@@ -140,7 +141,10 @@ class TestTaskFlowServiceController(base.TestCase):
         rediscond.assert_called_once_with(
             "test", self.jobboard_mock.__enter__(),
             persistence=self.persistence_mock.__enter__(),
-            engine='parallel')
+            engine='parallel',
+            engine_options={
+                'max_workers': MAX_WORKERS,
+            })
         self.conf.config(group="task_flow",
                          jobboard_backend_driver='zookeeper_taskflow_driver')