Class PubSubWorkerExtension

distributed.pubsub.PubSubWorkerExtension

Extend Dask's Worker with routes to handle PubSub machinery

Declaration

class PubSubWorkerExtension

Documentation

Methods

▷ def __init__(self, worker)
source link
▷ def add_subscriber(self, name=None, address=None, **info)
source link
▷ def cleanup(self)
source link
▷ def publish_scheduler(self, name=None, publish=None)
source link
▷ def remove_subscriber(self, name=None, address=None)
source link
▷ def trigger_cleanup(self)
source link

Reexports

Imported in distributed.worker.