diff --git a/taskflow/conductors/base.py b/taskflow/conductors/base.py index 750d8cff..694b213b 100644 --- a/taskflow/conductors/base.py +++ b/taskflow/conductors/base.py @@ -46,10 +46,7 @@ class Conductor(object): self._name = name self._jobboard = jobboard self._engine = engine - if not engine_options: - self._engine_options = {} - else: - self._engine_options = engine_options.copy() + self._engine_options = misc.ensure_dict(engine_options) self._persistence = persistence self._lock = threading.RLock() self._notifier = notifier.Notifier()