Class PublishExtension

distributed.publish.PublishExtension

An extension for the scheduler to manage collections

Declaration

class PublishExtension

Documentation

*  publish_list
*  publish_put
*  publish_get
*  publish_delete

Methods

▷ def __init__(self, scheduler)
source link
▷ def delete(self, comm=None, name=None)
source link
▷ def get(self, stream, name=None, client=None)
source link
▷ def list(self, *args)
source link
▷ def put(self, comm=None, keys=None, data=None, name=None, override=False, client=None)
source link

Reexports

Imported in distributed.scheduler.