U ){f@sddlZddlmZddlmZmZmZddlmZddlm Z ddlm Z dZ Gdd d ej Z eGd d d Zeeed d dZeeedddZdS)N) TracebackType)finalOptionalType)events) exceptions)tasks)Timeouttimeout timeout_atc@s eZdZdZdZdZdZdZdS)_StatecreatedactiveZexpiringexpiredfinishedN)__name__ __module__ __qualname__CREATEDENTEREDEXPIRINGEXPIREDEXITEDrrQ/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/taskgroup/timeouts.pyr s r c@seZdZeeddddZeedddZeedddd Zedd d Z e dd d Z ddddZ ee eeeeeeedddZddddZdS)r NwhenreturncCstj|_d|_d|_||_dSN)r r_state_timeout_handler_task_when)selfrrrr__init__!szTimeout.__init__)rcCs|jSr)r"r#rrrr(sz Timeout.whencCs|jtjk st|jtjk r0td|jjd||_|jdk rJ|j |dkrZd|_n4t }|| kr~| |j|_n|||j|_dS)NzCannot change state of z Timeout)rr rAssertionErrorr RuntimeErrorvaluer"r cancelrget_running_looptime call_soon _on_timeoutcall_at)r#rlooprrr reschedule+s    zTimeout.reschedulecCs|jtjtjfkS)z$Is timeout expired during execution?)rr rrr%rrrr@szTimeout.expiredcCs\dg}|jtjkr<|jdk r(t|jdnd}|d|d|}d|jjd|dS)Nzwhen= z )rr rr"roundappendjoinr()r#inforZinfo_strrrr__repr__Ds   zTimeout.__repr__cs4tj|_t|_|jdkr$td||j|S)Nz$Timeout should be used inside a task) r rrr current_taskr!r'r0r"r%rrr __aenter__Ls    zTimeout.__aenter__)exc_typeexc_valexc_tbrcsz|jtjtjfkst|jdk r0|jd|_|jtjkrbtj|_|j dkrv|t j krvt n|jtjkrvtj |_dS)Nr)rr rrr&r r)rr!ZuncancelrCancelledError TimeoutErrorr)r#r=r>r?rrr __aexit__Ts    zTimeout.__aexit__cCs,|jtjkst|jtj|_d|_dSr)rr rr&r!r)rr r%rrrr-ls zTimeout._on_timeout)rrrrfloatr$rr0boolrstrr:r<r BaseExceptionrrBr-rrrrr s  r )delayrcCs$t}t|dk r||ndS)a Timeout async context manager. Useful in cases when you want to apply timeout logic around block of code or in cases when asyncio.wait_for is not suitable. For example: >>> async with asyncio.timeout(10): # 10 seconds timeout ... await long_running_task() delay - value in seconds or None to disable timeout logic long_running_task() is interrupted by raising asyncio.CancelledError, the top-most affected timeout() context manager converts CancelledError into TimeoutError. N)rr*r r+)rGr/rrrr tsr rcCst|S)abSchedule the timeout at absolute time. Like timeout() but argument gives absolute time in the same clock system as loop.time(). Please note: it is not POSIX time but a time with undefined starting base, e.g. the time of the system power on. >>> async with asyncio.timeout_at(loop.time() + 10): ... await long_running_task() when - a deadline when timeout occurs or None to disable timeout logic long_running_task() is interrupted by raising asyncio.CancelledError, the top-most affected timeout() context manager converts CancelledError into TimeoutError. )r )rrrrr sr )enumtypesrtypingrrrasynciorrr__all__Enumr r rCr r rrrrs    U