Skip to content
Snippets Groups Projects
Commit 23f52875 authored by Wout De Nolf's avatar Wout De Nolf
Browse files

support positional arguments

parent 818c01ea
No related branches found
No related tags found
1 merge request!71Pypushflow api change to stop a workflow
......@@ -4,20 +4,22 @@ from ewokscore.inittask import instantiate_task
INFOKEY = "_noinput"
def run(**inputs):
def run(*args, **kwargs):
"""Main of actor execution.
:param **kw: output hashes from previous tasks
:returns dict: output hashes
"""
info = inputs.pop(INFOKEY)
info = kwargs.pop(INFOKEY)
varinfo = info["varinfo"]
execinfo = info["execinfo"]
if args:
kwargs.update(enumerate(args))
task = instantiate_task(
info["node_id"],
info["node_attrs"],
inputs=inputs,
inputs=kwargs,
varinfo=varinfo,
execinfo=execinfo,
)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment