pypushflow.persistence.mongo.MongoWorkflowDbClient¶

class pypushflow.persistence.mongo.MongoWorkflowDbClient[source]¶

Bases: WorkflowDbClient

Client interface of a Mongo database for storing workflow executions.

classmethod apply_actorinfo_filters(info)¶

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

connect(*args, **kw)¶

disconnect(*args, **kw)¶

endActor(actorId, status='finished')[source]¶

Return type:: None

endWorkflow(status='finished')[source]¶

Return type:: None

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

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

getActorInfo(actorId)[source]¶

Return type:: None

getWorkflowInfo()[source]¶

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)[source]¶

Parameters:

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

startWorkflow(name)[source]¶

Parameters:: name (str) –

updateActorInfo(actorId, info)[source]¶

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

updateWorkflowInfo(info)[source]¶

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