pypushflow.tests.test_workflow2.Workflow2¶

class pypushflow.tests.test_workflow2.Workflow2(name)[source]¶

Bases: Workflow

Workflow with error handling, containing one start actor, one python actor and one stop actor.

The python actor throws an exception.

addActorRef(actorRef)¶

connectOnError(actor)¶

endWorkflow(status)¶

getActorPath()¶

getListActorRef()¶

property pool¶

run(inData, timeout=None, **pool_options)¶

setStatus(status)¶

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

Parameters:

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

property stop_exception: BaseException | None¶

triggerOnError(inData)¶