Class LockExtension

distributed.lock.LockExtension

An extension for the scheduler to manage Locks

Declaration

class LockExtension

Documentation

This adds the following routes to the scheduler

*  lock_acquire
*  lock_release

Methods

▷ def __init__(self, scheduler)
source link
▷ def release(self, comm=None, name=None, id=None)
source link

Reexports

Imported in distributed.scheduler.