Class PubSubClientExtension

distributed.pubsub.PubSubClientExtension

Extend Dask's Client with handlers to handle PubSub machinery

Declaration

class PubSubClientExtension

Documentation

Methods

▷ def __init__(self, client)
source link
▷ def cleanup(self)
source link
▷ def trigger_cleanup(self)
source link

Reexports

Imported in distributed.client.