ԋg tddlmZddlZddlZddlmZej eZe Z GddeZ y)) annotationsN) SemaphorecPeZdZdZdeddffd Zd fd ZdZdZdZ dZ xZ S) LockaDistributed Centralized Lock .. warning:: This is using the ``distributed.Semaphore`` as a backend, which is susceptible to lease overbooking. For the Lock this means that if a lease is timing out, two or more instances could acquire the lock at the same time. To disable lease timeouts, set ``distributed.scheduler.locks.lease-timeout`` to `inf`, e.g. .. code-block:: python with dask.config.set({"distributed.scheduler.locks.lease-timeout": "inf"}): lock = Lock("x") ... Note, that without lease timeouts, the Lock may deadlock in case of cluster downscaling or worker failures. Parameters ---------- name: string (optional) Name of the lock to acquire. Choosing the same name allows two disconnected processes to coordinate a lock. If not given, a random name will be generated. client: Client (optional) Client to use for communication with the scheduler. If not given, the default global client will be used. Examples -------- >>> lock = Lock('x') # doctest: +SKIP >>> lock.acquire(timeout=1) # doctest: +SKIP >>> # do things with protected resource >>> lock.release() # doctest: +SKIP Nc|turddl}|jdtd|xs!dt j j z|_t|%d|||y)NrzYThe `client` parameter is deprecated. It is no longer necessary to pass a client to Lock.) stacklevelzlock-) max_leasesname scheduler_rpcloop) _no_valuewarningswarnDeprecationWarninguuiduuid4hexr super__init__)selfr clientr rr __class__s 0lib/python3.12/site-packages/distributed/lock.pyrz Lock.__init__3sg  "  MMk"   6Gdjjl&6&66  '  cF|s| tdd}t| |S)a/Acquire the lock Parameters ---------- blocking : bool, optional If false, don't wait on the lock in the scheduler at all. timeout : string or number or timedelta, optional Seconds to wait on the lock in the scheduler. This does not include local coroutine time, network transfer time, etc.. It is forbidden to specify a timeout when blocking is false. Instead of number of seconds, it is also possible to specify a timedelta in string format, e.g. "200ms". Examples -------- >>> lock = Lock('x') # doctest: +SKIP >>> lock.acquire(timeout="1s") # doctest: +SKIP Returns ------- True or False whether or not it successfully acquired the lock z/can't specify a timeout for a non-blocking callr)timeout) ValueErrorracquire)rblockingrrs rr z Lock.acquireKs0." !RSSGww//rctK|jj|jd{}|dk(S7 w)Nr r ) schedulersemaphore_valuer )rvals r_lockedz Lock._lockedhs3NN22 2BBaxCs *86 8c8|j|jSN)syncr'rs rlockedz Lock.lockedlsyy&&rc|jSr)r#r+s r __getstate__zLock.__getstate__os yyrc(|j|y)Nr#)r)rstates r __setstate__zLock.__setstate__rs 5 !r)TN) __name__ __module__ __qualname____doc__rrr r'r,r.r1 __classcell__)rs@rrr s5#N   00:'"rr) __future__rloggingrdistributed.semaphorer getLoggerr2loggerobjectrrrrr>s8" +   8 $ H f"9f"r