pypushflow.persistence.besdb.BesWorkflowDbClient#

class pypushflow.persistence.besdb.BesWorkflowDbClient(url, request_id=None, initiator=None, host=None, port=None)[source]#

Bases: PyMongoWorkflowDbClient

Client of the BES Mongo database for storing workflow executions.

Parameters:

  • url (str)

  • request_id (Optional[str])

  • initiator (Optional[str])

  • host (Optional[str])

  • port (Optional[str])

classmethod apply_actorinfo_filters(info)#
Parameters:

info (dict)

Return type:

dict

connect()#
disconnect()#
endActor(actorId, status='finished')#
Return type:

None

endWorkflow(status='finished')#
Return type:

None

ensureEndWorkflow()#
Return type:

None

generateActorId()#
Return type:

ObjectId

generateWorkflowId()[source]#
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