bobocep.cep.engine.decider.pubsub.BoboDeciderSubscriber

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

Bases: ABC

A decider subscriber interface.

__init__()
abstract on_decider_update(completed: List[BoboRunSerial], halted: List[BoboRunSerial], updated: List[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.