pypushflow.persistence.mongita.MemoryWorkflowDbClient#

class pypushflow.persistence.mongita.MemoryWorkflowDbClient[source]#

Client of an in-memory Mongo database for storing workflow executions. Used for testing purposes.

classmethod apply_actorinfo_filters(info)#

endActor(actorId, status='finished')#

endWorkflow(status='finished')#

ensureEndWorkflow()#

generateActorId()[source]#

generateWorkflowId()[source]#

getActorInfo(actorId)#

getWorkflowInfo()#

classmethod register_actorinfo_filter(method)#

setActorStatus(actorId, status)#

setWorkflowStatus(status)#

startActor(name, info=None)#

Parameters:

startWorkflow(name)#

updateActorInfo(actorId, info)#

updateWorkflowInfo(info)#