pypushflow.persistence.dummy.DummyWorkflowDbClient#

class pypushflow.persistence.dummy.DummyWorkflowDbClient[source]#

Bases: WorkflowDbClient

Client without a database. Used for testing purposes.

classmethod apply_actorinfo_filters(info)#
Parameters:

info (dict)

Return type:

dict

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

None

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

None

ensureEndWorkflow()[source]#
Return type:

None

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, 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