Class PubSubSchedulerExtension

Extend Dask's scheduler with routes to handle PubSub machinery

Declaration

class PubSubSchedulerExtension

▷ def __init__(self, scheduler)
source link
▷ def add_publisher(self, comm=None, name=None, worker=None)
source link
▷ def add_subscriber(self, comm=None, name=None, worker=None, client=None)
source link
▷ def handle_message(self, name=None, msg=None, worker=None, client=None)
source link
▷ def remove_publisher(self, comm=None, name=None, worker=None)
source link
▷ def remove_subscriber(self, comm=None, name=None, worker=None, client=None)
source link