o $i@s2ddlmZddlmZededefddZdS))Callable) OldAPIStackfuncreturncsfdd}|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 s~z"|j|g|Ri|WdWS1swYWdSty>}zd|jdvr8td||d}~ww)Nzhas no attribute '_lock'rzhObject {} must have a `self._lock` property (assigned to a threading.RLock() object in its constructor)!)_lockAttributeErrorargsformat)selfakerV/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/rllib/utils/threading.pywrappers(zwith_lock..wrapperr)rrrrr with_locks  rN)typingrray.rllib.utils.annotationsrrrrrrs