ewokscore.engine_interface.WorkflowEngineWithSerialization#

class ewokscore.engine_interface.WorkflowEngineWithSerialization[source]#

Bases: WorkflowEngine

Ewoks engines with graph serialization capabilities.

abstract deserialize_graph(graph, *, inputs=None, representation=None, root_dir=None, root_module=None, **deserialize_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

abstract execute_graph(graph, *, inputs=None, load_options=None, varinfo=None, execinfo=None, task_options=None, outputs=None, merge_outputs=True, **execute_options)#

Execute a computional Ewoks graph.

Parameters:

  • graph (TaskGraph)

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

Return type:

Optional[dict]

abstract get_graph_representation(graph)[source]#

Return the representation if the engine recognizes the graph object.

Parameters:

graph (Any)

Return type:

Optional[str]

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

Convert the canonical computational graph representation TaskGraph to another representation.

Parameters:

  • graph (TaskGraph)

  • destination (Any)

  • representation (Optional[str])

Return type:

Any