MfnddlZddlZddlZddlZddlmZmZmZGddZGddZ dS)N)AnyDictUnioncNeZdZdZd dZdZdededdffd Zdeddfd Z xZ S) _CVarzStorage utility for Local.returnNc8tjd|_dS)Nz asgiref.local) contextvars ContextVar_dataselfs L/var/www/surfInsights/venv3-11/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 getKeyErrorAttributeErrorrkeystorage_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 rset)rrrr __class__s rrz_CVar.__setattr__s] '>>77&&sE22 2++#s ~&&&&&rc|ji}||vr||=|j|dSt|d|r)r rrrrs r __delattr__z_CVar.__delattr__s^++ . 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)rr,s rrzLocal.__init__DsL /%O-- 6  $%O--DMMM"GGDMMMrc#@K|jrk tjt|jdst |j_|jjVdS#t$r |jVYdSwxYw|j5|jVddddS#1swxYwYdS)Ncvar) r/asyncioget_running_loophasattrr4rr6 RuntimeErrorr2r s r _lock_storagezLocal._lock_storageQs   $ )(***t}f551).DM& m(((((('  $ $ $ m######  $." $ $m### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s#AA21A2< BBBc~|5}t||cdddS#1swxYwYdSr.)r;getattrrrstorages rrzLocal.__getattr__ts    ! ! )W7C(( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s 266c|dvr"t||S|5}t|||ddddS#1swxYwYdS)N)_localr4r/r2)rrr;setattr)rrrr?r s rrzLocal.__setattr__xs 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 $ $ $ $ $ $ $ $ $ $D)))))))) """""""rr+) r7rFr r0typingrrrrr+rrrJs##########NNNNNNNN@X"X"X"X"X"X"X"X"X"X"r