jg`ddlZddlZddlZddlZddlmZmZmZGddZGddZ y)N)AnyDictUnioncNeZdZdZd dZdZdededdffd Zdeddfd Z xZ S) _CVarzStorage utility for Local.returnNc8tjd|_y)Nz asgiref.local) contextvars ContextVar_dataselfs K/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/asgiref/local.py__init__z_CVar.__init__ s?J?U?U @  c~|jji} ||S#t$rt|d|wxYwNz object has no attribute )r getKeyErrorAttributeErrorrkeystorage_objects r __getattr__z_CVar.__getattr__sM+ N!#& & N D8+DSG!LM M Ns"<rvaluec|dk(rt|||S|jji}|||<|jj |y)Nr )super __setattr__r rset)rrrr __class__s rrz_CVar.__setattr__sH '>7&sE2 2+#s ~&rc|jji}||vr||=|jj|yt|d|r)r rrrrs r __delattr__z_CVar.__delattr__sK+ . s# JJNN> * D8+DSG!LM Mr)rN) __name__ __module__ __qualname____doc__rrstrrrr" __classcell__r s@rrrsA$ N's'3'4'NsNtNrrcdeZdZdZd 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 |_yN)_thread_critical threadingRLock _thread_locklocal_storager)rr,s rrzLocal.__init__Ds8 /%OO- %OO-DM"GDMrc#vK|jr] tjt|jdst |j_|jj y|j5|jdddy#t$r|jYywxYw#1swYyxYww)Ncvar) r/asyncioget_running_loophasattrr4rr6 RuntimeErrorr2r s r _lock_storagezLocal._lock_storageQs   )((*t}}f5).DMM& mm((("" $mm# $ $/  $ mm#  $. $ $s@ B9BAB98B- B9B*'B9)B**B9-B62B9cf|j5}t||cdddS#1swYyxYwr.)r;getattrrrstorages rrzLocal.__getattr__ts/    ! )W7C( ) ) )s '0c|dvrt|||S|j5}t|||dddy#1swYyxYw)N)_localr4r/r2)rrr;setattr)rrrr?r s rrzLocal.__setattr__xsM L L7&sE2 2    ! )W GS% ( ) ) )s =Acf|j5}t||dddy#1swYyxYwr.)r;delattrr>s rr"zLocal.__delattr__~s/    ! "W GS ! " " "s '0)F) r#r$r%r&boolr contextlibcontextmanagerr;rrr"r(r)s@rr+r+(sE6 $ $ $ $ $D)) "rr+) r7rFr r0typingrrrrr+rrrJs0##NN@X"X"r