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

task_options dictionary for task instantiation to allow future task constructor arguments

parent 64080637
No related branches found
No related tags found
1 merge request!104add optional time profiling
Pipeline #205260 failed
......@@ -521,11 +521,11 @@ class EwoksWorkflow(Workflow):
self,
varinfo: Optional[dict] = None,
execinfo: Optional[dict] = None,
profile_directory: Optional[str] = None,
task_options: Optional[dict] = None,
**pool_options,
) -> Generator[None, None, None]:
self.startargs[ppfrunscript.INFOKEY]["varinfo"] = varinfo
self.startargs[ppfrunscript.INFOKEY]["profile_directory"] = profile_directory
self.startargs[ppfrunscript.INFOKEY]["task_options"] = task_options
graph = self.__ewoksgraph.graph
with events.workflow_context(execinfo, workflow=graph) as execinfo:
self.startargs[ppfrunscript.INFOKEY]["execinfo"] = execinfo
......
......@@ -13,7 +13,7 @@ def run(*args, **kwargs):
info = kwargs.pop(INFOKEY)
varinfo = info["varinfo"]
execinfo = info["execinfo"]
profile_directory = info["profile_directory"]
task_options = info["task_options"]
if args:
kwargs.update(enumerate(args))
......@@ -23,7 +23,7 @@ def run(*args, **kwargs):
inputs=kwargs,
varinfo=varinfo,
execinfo=execinfo,
profile_directory=profile_directory,
task_options=task_options,
)
task.execute()
......
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