ewoksdask.engine.DaskWorkflowEngine

class ewoksdask.engine.DaskWorkflowEngine

Bases: WorkflowEngine

execute_graph(graph, *, inputs=None, load_options=None, varinfo=None, execinfo=None, task_options=None, outputs=None, merge_outputs=True, scheduler=None, scheduler_options=None)

Execute a computional Ewoks graph.

Parameters:

• graph (Any)

• inputs (Optional[List[dict]])

• load_options (Optional[dict])

• varinfo (Optional[dict])

• execinfo (Union[Mapping, bool, str, None])

• task_options (Optional[dict])

• outputs (Optional[List[dict]])

• merge_outputs (Optional[bool])

• scheduler (Union[dict, str, None, Client])

• scheduler_options (Optional[dict])

Return type:

dict