pypushflow.persistence.interface.WorkflowDbClient

class pypushflow.persistence.interface.WorkflowDbClient[source]

Bases: object

Client interface of a database for storing workflow executions.

classmethod apply_actorinfo_filters(info)[source]
Parameters:

info (dict) –

Return type:

dict

connect(*args, **kw)[source]
disconnect(*args, **kw)[source]
endActor(actorId, status='finished')[source]
Return type:

None

endWorkflow(status='finished')[source]
Return type:

None

getActorInfo(actorId)[source]
Return type:

None

getWorkflowInfo()[source]
Return type:

Optional[dict]

classmethod get_dbclient_class(name)[source]
classmethod register_actorinfo_filter(method)[source]
Parameters:

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

setActorStatus(actorId, status)[source]
Parameters:

status (str) –

Return type:

None

setWorkflowStatus(status)[source]
Parameters:

status (str) –

Return type:

None

startActor(name, info=None, script=None)[source]
Parameters:

  • name (str) –

  • info (Optional[dict]) –

  • script (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