pypushflow.tests.test_workflow1.Workflow1¶
- class pypushflow.tests.test_workflow1.Workflow1(name)[source]¶
Bases:
WorkflowWorkflow containing one start actor, one python actor and one stop actor.
- 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)¶