ewokscore.graph.execute.sequential.execute_graph#

ewokscore.graph.execute.sequential.execute_graph(graph, varinfo=None, execinfo=None, task_options=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])

  • task_options (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]]