ewoksppf.bindings.EwoksWorkflow¶

class ewoksppf.bindings.EwoksWorkflow(ewoksgraph, pre_import=None, **kw)[source]¶

Bases: Workflow

Parameters:

ewoksgraph (TaskGraph)
pre_import (Optional[bool])

addActorRef(actorRef)¶

connectOnError(actor)¶

endWorkflow(status)¶

getActorPath()¶

getListActorRef()¶

graph_to_actors(taskgraph)[source]¶

Parameters:: taskgraph (TaskGraph)

property pool¶

run(startargs=None, raise_on_error=True, outputs=None, merge_outputs=True, timeout=None, **execute_options)[source]¶

Parameters:

startargs (Optional[dict])
raise_on_error (Optional[bool])
outputs (Optional[List[dict]])
merge_outputs (Optional[bool])
timeout (Optional[float])

setStatus(status)¶

stop(reason='interrupt workflow', forced_interruption=None)¶

Parameters:

reason (str)
forced_interruption (Optional[bool])

property stop_exception: BaseException | None¶

triggerOnError(inData)¶