2iUdZddlmZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z ejZded <ej"dZded <ej&Zej&Ze d ZGd d ej,eZGddej,eZ d ddZ d ddZddddZddddZy)z Utilities to ease the differences between async and sync code. These object offer a similar interface between sync and async versions; the script async_to_sync.py will replace the async names with the sync names when generating the sync version. ) annotationsN)Any TypeAlias)Callable Coroutine)TypeVarrWorkerAWorkerTc&eZdZdZddfd ZxZS)Queuez> A Queue subclass with an interruptible get() method. c.|d}t|||S)Ng@)blocktimeout)superget)selfrr __class__s O/var/www/html/secretsanta/venv/lib/python3.12/site-packages/psycopg/_acompat.pyrz Queue.get"s ?(Gw{{88)TN)rboolr float | Nonereturnr )__name__ __module__ __qualname____doc__r __classcell__)rs@rrrs99rrc eZdZy)AQueueN)rrrrrr!r!)srr!c6tj|||S)z, Equivalent to asyncio.create_task. )name)asyncio create_task)fargsr$s raspawnr)-s   q$xd 33rcXtj|||d}|j|S)z= Equivalent to creating and running a daemon thread. T)targetr(r$daemon) threadingThreadstart)r'r(r$ts rspawnr18s( 4EAGGI HrrcKtj|} |3tjtj||d{y|d{ y77#tj$rYywxYww)7 Equivalent to asyncio.gather or Thread.join() Nr2)r%gatherwait_forshield TimeoutError)rtaskswaits ragatherr;Est >>5 !D  ""7>>$#7I I I  JJ  J       sXA4/AAA A4 AAAA4AAA1.A40A11A4cV|D]$}|js|j|&y)r4N)is_alivejoin)rr9r0s rr5r5Us*zz|  wr)r"N)r'z(Callable[..., Coroutine[Any, Any, None]]r(tuple[Any, ...]r$ str | Nonerzasyncio.Task[None])r'zCallable[..., Any]r(r?r$r@rthreading.Thread)r9zasyncio.Task[Any]rrrNone)r9rArrrrB)r __future__rqueuer%r-typingrrcollections.abcrr_compatr r.r __annotations__Taskr LockALockr rr!r)r1r;r5r"rrrLs# !/$$ $\\$''~~  CL 9EKKN 9 W]]1  4/4 4 4 4           FJ  >Br