ewokscore.graph.execute.sequential#

Functions

execute_graph(graph[, varinfo, execinfo, ...])

Sequential execution of DAGs.

instantiate_task(graph, node_id, **kw)

Named arguments are dynamic input and Variable config.

instantiate_task_static(graph, node_id[, ...])

Instantiate destination task while no access to the dynamic inputs.

successor_counter(graph)

param graph: