o ^i)@sddlmZddlZddlZddlmZddlmZmZm Z ddl m Z ddl m Z ddl m Z dd lmZdd lmZd ZGd d d ejZGdddZeGdddeZdddZdddZdS)) annotationsN) TracebackType)finalOptionalType)events) exceptions)tasks)install)Self)Timeouttimeout timeout_atc@s eZdZdZdZdZdZdZdS)_StatecreatedactiveexpiringexpiredfinishedN)__name__ __module__ __qualname__CREATEDENTEREDEXPIRINGEXPIREDEXITEDrrW/var/www/html/stock_analysis/be/venv/lib/python3.10/site-packages/taskgroup/timeouts.pyrs rc@s`eZdZdZd!ddZd"dd Zd!d d Zd#d dZd$ddZd%ddZ d&ddZ d'ddZ d S)(_TimeoutzAsynchronous context manager for cancelling overdue coroutines. Use `timeout()` or `timeout_at()` rather than instantiating this class directly. whenOptional[float]returnNonecCstj|_d|_d|_||_dS)zSchedule a timeout that will trigger at a given loop time. - If `when` is `None`, the timeout will never trigger. - If `when < loop.time()`, the timeout will trigger on the next iteration of the event loop. N)rr_state_timeout_handler_task_when)selfr!rrr__init__)s z_Timeout.__init__cCs|jS)zReturn the current deadline.)r(r)rrrr!6sz _Timeout.whencCs|jtjur|jtjurtdtd|jjd||_|jdur'|j|dur0d|_dSt }|| krC| |j |_dS|||j |_dS)zReschedule the timeout.zTimeout has not been enteredzCannot change state of z TimeoutN)r%rrr RuntimeErrorvaluer(r&cancelrget_running_looptime call_soon _on_timeoutcall_at)r)r!looprrr reschedule:s      z_Timeout.rescheduleboolcCs|jtjtjfvS)z$Is timeout expired during execution?)r%rrrr+rrrrQsz_Timeout.expiredstrcCs\dg}|jtjur|jdurt|jdnd}|d|d|}d|jjd|dS)Nzwhen= z )r%rrr(roundappendjoinr-)r)infor!info_strrrr__repr__Us   z_Timeout.__repr__r csX|jtjur tdt}|durtdtj|_||_|j|_ | |j |S)Nz Timeout has already been enteredz$Timeout should be used inside a task) r%rrr,r current_taskrr' cancelling _cancellingr5r()r)taskrrr __aenter__]s   z_Timeout.__aenter__exc_typeOptional[Type[BaseException]]exc_valOptional[BaseException]exc_tbOptional[TracebackType]Optional[bool]cs|jtjtjfvs J|jdur|jd|_|jtjur5tj|_|j|j kr3|t j ur3t |dS|jtjur?tj |_dSN)r%rrrr&r.rr'uncancelrErCancelledError TimeoutErrorrr)rHrJrLrrr __aexit__is     z_Timeout.__aexit__cCs:|jdusJ|jtjusJ|jtj|_d|_dSrO)r'r%rrr.rr&r+rrrr2s   z_Timeout._on_timeoutN)r!r"r#r$)r#r")r#r6)r#r7r#r rHrIrJrKrLrMr#rN)r#r$) rrr__doc__r*r!r5rrBrGrTr2rrrrr #s      r cs2eZdZUded<dfdd ZdddZZS)r zcontextlib.AsyncExitStack_Timeout__stackr#r c st4IdH*}|tIdHtIdH|tj| |_ WdIdH|S1IdHs9wY|SrO) contextlibAsyncExitStackenter_async_context_installinstall_uncancelsuperrGpush_async_exitrTpop_allrX)r)stack __class__rrrGs zTimeout.__aenter__rHrIrJrKrLrMrNcs|j|||IdHSrO)rXrTrSrrrrTszTimeout.__aexit__rUrV)rrr__annotations__rGrT __classcell__rrrbrr s r delayr"r#cCs&t}t|dur||SdS)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 r0)rfr4rrrrsrr!cCst|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 )r!rrrrsr)rfr"r#r )r!r"r#r ) __future__rrYenumtypesrtypingrrrasynciorrr r8r r\typing_extensionsr __all__Enumrr r rrrrrrs"       j