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, varinfo=None, execinfo=None, task_options=None, max_workers=None, scaling_workers=True, pool_type=None, **pool_options)[source]#
Parameters:

  • startargs (Optional[dict])

  • raise_on_error (Optional[bool])

  • outputs (Optional[List[dict]])

  • merge_outputs (Optional[bool])

  • timeout (Optional[float])

  • varinfo (Optional[dict])

  • execinfo (Optional[dict])

  • task_options (Optional[dict])

  • max_workers (Optional[int])

  • scaling_workers (bool)

  • pool_type (Optional[str])

Return type:

dict

setStatus(status)#
stop(reason='interrupt workflow', forced_interruption=None)#
Parameters:

  • reason (str)

  • forced_interruption (Optional[bool])

property stop_exception: BaseException | None#
triggerOnError(inData)#