ewokscore.engine.CoreWorkflowEngine#

class ewokscore.engine.CoreWorkflowEngine[source]#

Bases: WorkflowEngineWithSerialization

deserialize_graph(graph, *, inputs=None, representation=None, root_dir=None, root_module=None, **load_options)[source]#

Convert a computational graph representation to the canonical in-memory representation TaskGraph.

Parameters:

  • graph (Any)

  • inputs (Optional[List[dict]])

  • representation (Optional[str])

  • root_dir (Union[str, Path, None])

  • root_module (Optional[str])

Return type:

TaskGraph

execute_graph(graph, *, inputs=None, load_options=None, varinfo=None, execinfo=None, task_options=None, outputs=None, merge_outputs=True, output_tasks=False, raise_on_error=True)[source]#

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])

  • output_tasks (Optional[bool])

  • raise_on_error (Optional[bool])

Return type:

Union[Dict[Union[str, int, tuple], Task], Dict[str, Any]]

get_graph_representation(graph)[source]#

Return the representation if the engine recognizes the graph object.

Parameters:

graph (Any)

Return type:

Optional[str]

serialize_graph(graph, destination, *, representation=None, **save_options)[source]#

Convert the canonical computational graph representation TaskGraph to another representation.

Parameters:

  • graph (TaskGraph)

  • representation (Optional[str])

Return type:

Union[str, dict]