pypushflow.Workflow.Workflow#

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

Bases: PyPushflowLoggedObject

Parameters:

  • stop_on_signals (bool)

  • forced_interruption (bool)

  • stop_signals (Optional[Sequence])

  • db_options (Optional[dict])

addActorRef(actorRef)[source]#
connectOnError(actor)[source]#
endWorkflow(status)[source]#
getActorPath()[source]#
getListActorRef()[source]#
property pool#
run(inData, timeout=None, max_workers=None, scaling_workers=True, pool_type=None, **pool_options)[source]#
Parameters:

  • timeout (Optional[float])

  • max_workers (Optional[int])

  • scaling_workers (bool)

  • pool_type (Optional[str])

Return type:

dict

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