From ee2deb0912050d5983d84d92d46f97bf712fb7c7 Mon Sep 17 00:00:00 2001 From: Matthew Feickert Date: Mon, 7 Feb 2022 18:22:56 -0600 Subject: [PATCH] Move coerce_data_arg to creators --- src/yadage/creators.py | 3 +++ src/yadage/state_providers/__init__.py | 1 - 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/yadage/creators.py b/src/yadage/creators.py index 19834be7..260608e0 100644 --- a/src/yadage/creators.py +++ b/src/yadage/creators.py @@ -10,6 +10,8 @@ from .controllers import setup_controller from .wflow import YadageWorkflow +from yadage.utils import coerce_data_arg + log = logging.getLogger(__name__) handlers, creator = handler_decorator() @@ -44,6 +46,7 @@ def local_workflows( prepares initial workflow object and returns controller """ + dataarg = coerce_data_arg(dataarg) rootprovider = state_provider_from_string(dataarg, dataopts) if not workflow_json and not workflow: diff --git a/src/yadage/state_providers/__init__.py b/src/yadage/state_providers/__init__.py index 9a2a6680..a4d05751 100644 --- a/src/yadage/state_providers/__init__.py +++ b/src/yadage/state_providers/__init__.py @@ -80,7 +80,6 @@ def fromenv_provider(dataarg, dataopts): def state_provider_from_string(dataarg, dataopts=None): - dataarg = coerce_data_arg(dataarg) dataopts = dataopts or {} for k in providersetup_handlers.keys(): if dataarg.startswith(k):