ewoksppf.engine.PpfWorkflowEngine#

class ewoksppf.engine.PpfWorkflowEngine[source]#

Bases: WorkflowEngine

execute_graph(graph, *, inputs=None, load_options=None, varinfo=None, execinfo=None, task_options=None, outputs=None, merge_outputs=True, pre_import=None, stop_on_signals=False, forced_interruption=False, stop_signals=None, db_options=None, startargs=None, raise_on_error=True, timeout=None, pool_type=None, pool_options=None, max_workers=None, scaling_workers=True, **deprecated_pool_options)[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])

  • pre_import (Optional[bool])

  • stop_on_signals (bool)

  • forced_interruption (bool)

  • stop_signals (Optional[Sequence])

  • db_options (Optional[dict])

  • startargs (Optional[dict])

  • raise_on_error (Optional[bool])

  • timeout (Optional[float])

  • pool_type (Optional[str])

  • pool_options (Optional[dict])

  • max_workers (Optional[int])

  • scaling_workers (bool)

Return type:

dict