R j0`SSKrSSKrSSKrSSKrSSKJrJrJr "SS5r"SS5r g)N)AnyDictUnionc^^\rSrSrSrS SjrSrS\S\SS4U4S jjr S\SS4S jr S r U=r $) _CVarzStorage utility for Local.returnNc:[R"S5Ulg)Nz asgiref.local) contextvars ContextVar_data)selfs 9D:\diplom_project\venv\Lib\site-packages\asgiref/local.py__init___CVar.__init__ s?J?U?U @  cURR05nX!$![a [U<SU<35ef=fNz object has no attribute )r getKeyErrorAttributeErrorrkeystorage_objects r __getattr___CVar.__getattr__sK+ N!& & N D8+DSG!LM M Ns!>rvaluec>US:Xa[TU]X5$URR05R 5nX#U'URR U5 g)Nr )super __setattr__r rcopyset)rrrr __class__s rr _CVar.__setattr__sM '>7&s2 2+002#s ~&rcURR05R5nX;aX! URRU5 g[ U<SU<35er)r rr!r"rrs r __delattr___CVar.__delattr__sP+002  # JJNN> * D8+DSG!LM Mr)r )r N) __name__ __module__ __qualname____firstlineno____doc__rrstrrr r&__static_attributes__ __classcell__r#s@rrrsG$ N's'3'4'NsNtNNrrcr^\rSrSrSrS S\SS4Sjjr\RS5r Sr U4S jr S r S r U=r$) Local(aLocal 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_criticalr NcXl[R"5UlU U(a[R"5Ulg[ 5UlgN)_thread_critical threadingRLock _thread_locklocal_storager)rr4s rrLocal.__init__Ds6 /%OO- %OO-DM"GDMrc## UR(a{Sn[R"5 U(dURv g[ URS5(d[ 5URlURRv gUR URv SSS5 g![a SnNf=f!,(df  g=f7f)NTFcvar) r7asyncioget_running_loop RuntimeErrorr<hasattrrr?r:)ris_asyncs r _lock_storageLocal._lock_storageQs  H !((* mm#t}}f55).DMM& mm(((""mm##"3  !  !2#"s@CB3A/CC* C3 C?CCC CCcnUR5n[X!5sSSS5 $!,(df  g=fr6)rEgetattrrrstorages rrLocal.__getattr__ws$    !W7(" ! !s & 4c>US;a[TU]X5$UR5n[X1U5 SSS5 g!,(df  g=f)N)_localr<r7r:)rr rEsetattr)rrrrJr#s rr Local.__setattr__{s@ L L7&s2 2    !W G% (" ! !s = A cnUR5n[X!5 SSS5 g!,(df  g=fr6)rEdelattrrIs rr&Local.__delattr__s$    !W G !" ! !s & 4)r<r7r:)F)r(r)r*r+r,boolr contextlibcontextmanagerrErr r&r.r/r0s@rr2r2(sJ6 $ $ $#$#$J)) ""rr2) r@rTr r8typingrrrrr2rrrXs0##NN@["["r