ewokscore.graph.execute.sequential.execute_graph#
- ewokscore.graph.execute.sequential.execute_graph(graph, varinfo=None, execinfo=None, raise_on_error=True, outputs=None, merge_outputs=True, output_tasks=False)[source]#
Sequential execution of DAGs.
When output_tasks is True the arguments outputs and merge_outputs are ignored and instead of returning output values, it returns Task instances. This was introduced for testing.
- Parameters:
graph (
DiGraph
) –varinfo (
Optional
[dict
]) –execinfo (
Optional
[dict
]) –raise_on_error (
Optional
[bool
]) –outputs (
Optional
[List
[dict
]]) –merge_outputs (
Optional
[bool
]) –output_tasks (
Optional
[bool
]) –
- Return type:
Union
[Dict
[Union
[str
,int
,tuple
],Task
],Dict
[str
,Any
]]