&`i>ddlmZddlmZededefdZdS))Callable) OldAPIStackfuncreturncfd}|S)aUse as decorator (@withlock) around object methods that need locking. Note: The object must have a self._lock = threading.Lock() property. Locking thus works on the object level (no two locked methods of the same object can be called asynchronously). Args: func: The function to decorate/wrap. Returns: The wrapped (object-level locked) function. c |j5|g|Ri|cdddS#1swxYwYdS#t$r8}d|jdvr"td||d}~wwxYw)Nzhas no attribute '_lock'rzhObject {} must have a `self._lock` property (assigned to a threading.RLock() object in its constructor)!)_lockAttributeErrorargsformat)selfakers m/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/rllib/utils/threading.pywrapperzwith_lock..wrappers  + +tD*1***** + + + + + + + + + + + + + + + + + +   )QVAY66$$$*F4LL G s,0 # 0'0'0 A23A--A2)rrs` r with_lockrs#      NN)typingrray.rllib.utils.annotationsrrrrrrsa333333 H r