bobocep.dist.pubsub.BoboDistributedSubscriber

class bobocep.dist.pubsub.BoboDistributedSubscriber[source]

Bases: ABC

A distributed subscriber interface.

__init__()
abstract on_distributed_update(completed: List[BoboRunSerial], halted: List[BoboRunSerial], updated: List[BoboRunSerial]) → None[source]
Parameters:

  • completed – Completed runs.

  • halted – Halted runs.

  • updated – Updated runs.