pypushflow.Workflow.Workflow¶

class pypushflow.Workflow.Workflow(name, stop_on_signals=False, forced_interruption=False, stop_signals=None)[source]¶

Bases: PyPushflowLoggedObject

Parameters:

stop_on_signals (bool) –
forced_interruption (bool) –
stop_signals (Optional[Sequence]) –

addActorRef(actorRef)[source]¶

connectOnError(actor)[source]¶

endWorkflow(status)[source]¶

getActorPath()[source]¶

getListActorRef()[source]¶

property pool¶

run(inData, timeout=None, **pool_options)[source]¶

setStatus(status)[source]¶

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

Parameters:

reason (str) –
forced_interruption (Optional[bool]) –

property stop_exception: BaseException | None¶

triggerOnError(inData)[source]¶