Class QueueExtension

distributed.queues.QueueExtension

An extension for the scheduler to manage queues

Declaration

class QueueExtension

Documentation

This adds the following routes to the scheduler

*  queue_create
*  queue_release
*  queue_put
*  queue_get
*  queue_size

Methods

▷ def __init__(self, scheduler)
source link
▷ def create(self, comm=None, name=None, client=None, maxsize=0)
source link
▷ def future_release(self, name=None, key=None, client=None)
source link
▷ def qsize(self, comm=None, name=None, client=None)
source link
▷ def release(self, comm=None, name=None, client=None)
source link

Reexports

Imported in distributed.scheduler.