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