bobocep.cep.engine.decider.pubsub.BoboDeciderSubscriber

class bobocep.cep.engine.decider.pubsub.BoboDeciderSubscriber[source]

Bases: abc.ABC

A decider subscriber interface.

__init__()
abstract on_decider_update(completed: List[bobocep.cep.engine.decider.runserial.BoboRunSerial], halted: List[bobocep.cep.engine.decider.runserial.BoboRunSerial], updated: List[bobocep.cep.engine.decider.runserial.BoboRunSerial], local: bool) → None[source]
Parameters

  • completed – Completed runs.

  • halted – Halted runs.

  • updated – Updated runs.

  • local – True if the Decider update occurred locally; False if the update occurred on a remote (distributed) instance.