Module pubsub

distributed.pubsub

Classes

class Pub
Publish data with Publish-Subscribe pattern
class PubSubClientExtension
Extend Dask's Client with handlers to handle PubSub machinery
class PubSubSchedulerExtension
Extend Dask's scheduler with routes to handle PubSub machinery
class PubSubWorkerExtension
Extend Dask's Worker with routes to handle PubSub machinery
class Sub
Subscribe to a Publish/Subscribe topic