pypushflow.persistence.besdb.BesWorkflowDbClient¶

class pypushflow.persistence.besdb.BesWorkflowDbClient[source]¶

Bases: PyMongoWorkflowDbClient

Client of the BES Mongo database for storing workflow executions.

classmethod apply_actorinfo_filters(info)¶

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

connect(url=None)[source]¶

Parameters:: url (Optional[str]) –

disconnect(*args, **kw)¶

endActor(actorId, status='finished')¶

Return type:: None

endWorkflow(status='finished')¶

Return type:: None

generateActorId(oid=None)¶

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

generateWorkflowId(oid=None)[source]¶

Parameters:: oid (Optional[str]) –

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