sgh \ddlZddlZddlZddlZddlmZmZGddZGddZy)N)AnyUnioncXeZdZdZd dZdedefdZdededdffd Zdeddfd Z xZ S) _CVarzStorage utility for Local.returnNci|_yN)_data)selfs Q/var/www/enzed_healthcare/enzed_env/lib/python3.12/site-packages/asgiref/local.py__init__z_CVar.__init__ s =? keyc |j|} |jS#t$rt|d|wxYw#t$rt|d|wxYwNz object has no attribute )r KeyErrorAttributeErrorget LookupError)r rvars r __getattr__z_CVar.__getattr__sz N**S/C N779   N D8+DSG!LM M N  N D8+DSG!LM M Ns"?<Avaluec|dk(rt|||S|jj|}|$t j |x|j|<}|j |y)Nr )super __setattr__r r contextvars ContextVarset)r rrr __class__s r rz_CVar.__setattr__s[ '>7&sE2 2jjnnS! ;$/$:$:3$? ?DJJsOc rcZ||jvr|j|=yt|d|r)r r)r rs r __delattr__z_CVar.__delattr__"s0 $**  3 D8+DSG!LM Mr)rN) __name__ __module__ __qualname____doc__r strrrrr! __classcell__rs@r rrsR$@ Ns Ns Ns34NsNtNrrcdeZdZdZd deddfdZejdZdZ fdZ d Z xZ S) LocalaLocal storage for async tasks. This is a namespace object (similar to `threading.local`) where data is also local to the current async task (if there is one). In async threads, local means in the same sense as the `contextvars` module - i.e. a value set in an async frame will be visible: - to other async code `await`-ed from this frame. - to tasks spawned using `asyncio` utilities (`create_task`, `wait_for`, `gather` and probably others). - to code scheduled in a sync thread using `sync_to_async` In "sync" threads (a thread with no async event loop running), the data is thread-local, but additionally shared with async code executed via the `async_to_sync` utility, which schedules async code in a new thread and copies context across to that thread. If `thread_critical` is True, then the local will only be visible per-thread, behaving exactly like `threading.local` if the thread is sync, and as `contextvars` if the thread is async. This allows genuinely thread-sensitive code (such as DB handles) to be kept stricly to their initial thread and disable the sharing across `sync_to_async` and `async_to_sync` wrapped calls. Unlike plain `contextvars` objects, this utility is threadsafe. thread_criticalrNc||_tj|_||rtj|_yt |_yr )_thread_critical threadingRLock _thread_locklocal_storager)r r+s r r zLocal.__init__Es8 /%OO- %OO-DM"GDMrc#K|jrpd} tj|s|jyt |jdst |j_|jjy|j5|jdddy#t$rd}YwxYw#1swYyxYww)NTFcvar) r-asyncioget_running_loop RuntimeErrorr2hasattrrr4r0)r is_asyncs r _lock_storagezLocal._lock_storageRs  H !((* mm#t}}f5).DMM& mm((("" $mm# $ $3  !  !2 $ $s@CB#A%C B4 C# B1.C0B11C4B=9Ccf|j5}t||cdddS#1swYyxYwr )r:getattrr rstorages r rzLocal.__getattr__xs/    ! )W7C( ) ) )s '0c|dvrt|||S|j5}t|||dddy#1swYyxYw)N)_localr2r-r0)rrr:setattr)r rrr>rs r rzLocal.__setattr__|sM L L7&sE2 2    ! )W GS% ( ) ) )s =Acf|j5}t||dddy#1swYyxYwr )r:delattrr=s r r!zLocal.__delattr__s/    ! "W GS ! " " "s '0)F) r"r#r$r%boolr contextlibcontextmanagerr:rrr!r'r(s@r r*r*)sE6 $ $ $#$#$J)) "rr*) r5rErr.typingrrrr*rr rIs-NNB["["r