j0nddlZddlZddlZddlZddlmZmZmZGddZGddZ dS)N)AnyDictUnioncNeZdZdZd dZdZdededdffd Zdeddfd Z xZ S) _CVarzStorage utility for Local.returnNc8tjd|_dS)Nz asgiref.local) contextvars ContextVar_data)selfs \/var/www/finuniver-perm.ru/html/portfolio/venv/lib/python3.11/site-packages/asgiref/local.py__init__z_CVar.__init__ s?J?U @ @  c|ji} ||S#t$rt|d|wxYwNz object has no attribute )r getKeyErrorAttributeErrorr keystorage_objects r __getattr__z_CVar.__getattr__sa++ N!#& & N N N D!L!LS!L!LMM M Ns $Arvaluec|dkr"t||S|ji}|||<|j|dS)Nr )super __setattr__r rcopyset)r rrr __class__s rrz_CVar.__setattr__si '>>77&&sE22 2++0022#s ~&&&&&rc|ji}||vr||=|j|dSt |d|r)r rrrrrs r __delattr__z_CVar.__delattr__sj++0022 . s# JNN> * * * * * D!L!LS!L!LMM Mr)rN) __name__ __module__ __qualname____doc__rrstrrrr" __classcell__r s@rrrs$$    NNN's'3'4''''''NsNtNNNNNNNNrrc`eZdZdZd deddfdZejdZdZ fd Z 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. Fthread_criticalrNc||_tj|_||rtj|_dSt |_dSN)_thread_critical threadingRLock _thread_locklocal_storager)r r,s rrzLocal.__init__DsL /%O-- 6  $%O--DMMM"GGDMMMrc#PK|jrsd} tjn#t$rd}YnwxYw|s |jVdSt |jdst |j_|jjVdS|j5|jVddddS#1swxYwYdS)NTFcvar) r/asyncioget_running_loop RuntimeErrorr4hasattrrr6r2)r is_asyncs r _lock_storagezLocal._lock_storageQs-  ! $H !(**** ! ! !  ! ) m#####t}f551).DM& m((((((" $ $m### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s! 00 BB"Bc~|5}t||cdddS#1swxYwYdSr.)r<getattrr rstorages rrzLocal.__getattr__ws    ! ! )W7C(( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s 266c|dvr"t||S|5}t|||ddddS#1swxYwYdS)N)_localr4r/r2)rrr<setattr)r rrr@r s rrzLocal.__setattr__{s L L L77&&sE22 2    ! ! )W GS% ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )sAA"Ac|5}t||ddddS#1swxYwYdSr.)r<delattrr?s rr"zLocal.__delattr__s    ! ! "W GS ! ! ! " " " " " " " " " " " " " " " " " "s 377)F) r#r$r%r&boolr contextlibcontextmanagerr<rrr"r(r)s@rr+r+(s6 $ $ $ $ $ $ $#$#$#$J)))))))) """""""rr+) r7rGr r0typingrrrrr+rrrKs##########NNNNNNNN@["["["["["["["["["["r