ewoksorange.engine.OrangeWorkflowEngine

class ewoksorange.engine.OrangeWorkflowEngine

Bases: WorkflowEngineWithSerialization

deserialize_graph(graph, *, inputs=None, representation=None, root_dir=None, root_module=None, preserve_ows_info=True, title_as_node_id=False)

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

• preserve_ows_info (Optional[bool])

• title_as_node_id (Optional[bool])

Return type:

TaskGraph

execute_graph(graph, *, inputs=None, load_options=None, varinfo=None, execinfo=None, task_options=None, outputs=None, merge_outputs=True, error_on_duplicates=True, tmpdir=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])

• error_on_duplicates (bool)

• tmpdir (Optional[str])

Return type:

None

get_graph_representation(graph)

Return the representation if the engine recognizes the graph object.

Parameters:

graph (Any)

Return type:

Optional[str]

serialize_graph(graph, destination, *, representation=None, **serialize_options)

Convert the canonical computational graph representation TaskGraph to another representation.

Parameters:

• graph (TaskGraph)

• representation (Optional[str])

Return type:

Union[str, dict]