Class SemaphoreExtension

distributed.semaphore.SemaphoreExtension

An extension for the scheduler to manage Semaphores

Declaration

class SemaphoreExtension

Documentation

This adds the following routes to the scheduler

* semaphore_acquire
* semaphore_release
* semaphore_close
* semaphore_refresh_leases
* semaphore_register

Methods

▷ def __init__(self, scheduler)
source link
▷ def close(self, comm=None, name=None)
Hard close the semaphore without warning clients which still hold a lease.
source link
▷ def create(self, comm=None, name=None, max_leases=None)
source link
▷ def refresh_leases(self, comm=None, name=None, lease_ids=None)
source link
▷ def release(self, comm=None, name=None, lease_id=None)
source link

Reexports

Imported in distributed.scheduler.