pypushflow.persistence.mongita.MemoryWorkflowDbClient¶

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

Bases: MongoWorkflowDbClient

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

classmethod apply_actorinfo_filters(info)¶

Parameters:: info (dict) –
Return type:: dict

connect()[source]¶

disconnect(*args, **kw)[source]¶

endActor(actorId, status='finished')¶

Return type:: None

endWorkflow(status='finished')¶

Return type:: None

generateActorId(oid=None)[source]¶

Parameters:: oid (Optional[str]) –
Return type:: ObjectId

generateWorkflowId(oid=None)[source]¶

Parameters:: oid (Optional[str]) –
Return type:: ObjectId

getActorInfo(actorId)¶

Return type:: None

getWorkflowInfo()¶

Return type:: Optional[dict]

classmethod get_dbclient_class(name)¶

classmethod register_actorinfo_filter(method)¶

Parameters:: method (Callable[[dict], dict]) –

setActorStatus(actorId, status)¶

Parameters:: status (str) –
Return type:: None

setWorkflowStatus(status)¶

Parameters:: status (str) –
Return type:: None

startActor(name, info=None)¶

Parameters:

name (str) –
info (Optional[str]) –

startWorkflow(name)¶

Parameters:: name (str) –

updateActorInfo(actorId, info)¶

Parameters:: info (dict) –
Return type:: None

updateWorkflowInfo(info)¶

Parameters:: info (dict) –
Return type:: None