o #6d@sddlmZddlZddlmZddlmZddlmZm Z ddl m Z m Z m Z dd lmZGd d d e eZeZGd d d e d Zddd#ddZGddde eZd$d%ddZd$d&ddZd'ddZd(d!d"ZdS))) annotationsN) TracebackType)warn) TaskGroup TaskStatus)DeprecatedAsyncContextManagerDeprecatedAwaitableDeprecatedAwaitableFloat) get_asynclibc@seZdZdd ddZdS) _IgnoredTaskStatusNvalueobjectreturnNonecCsdSNselfrrriC:\Users\jesus\OneDrive\Desktop\erpjis_fastapi\backend\jisbackend\Lib\site-packages\anyio/_core/_tasks.pystartedz_IgnoredTaskStatus.startedr)rrrr)__name__ __module__ __qualname__rrrrrr sr c@seZdZdZejddd$d d Zd%d d Zed&ddZ e j d'ddZ ed(ddZ ed(ddZ e j d)ddZ d*ddZ d+d!d"Zd#S), CancelScopez Wraps a unit of work that can be made separately cancellable. :param deadline: The time (clock value) when this scope is cancelled automatically :param shield: ``True`` to shield the cancel scope from external cancellation FdeadlineshieldrfloatrboolrcCstj||dS)N)rr)r r)clsrrrrr__new__ szCancelScope.__new__r cCt)zCancel this scope immediately.NotImplementedErrorrrrrcancel%zCancelScope.cancelcCr$)z The time (clock value) when this scope is cancelled automatically. Will be ``float('inf')`` if no timeout has been set. r%r'rrrr)zCancelScope.deadlinerrcCr$rr%rrrrr3r)cCr$)z+``True`` if :meth:`cancel` has been called.r%r'rrr cancel_called7szCancelScope.cancel_calledcCr$)z ``True`` if this scope is shielded from external cancellation. While a scope is shielded, it will not receive cancellations from outside. r%r'rrrr<r*zCancelScope.shieldcCr$rr%rrrrrFr)cCr$rr%r'rrr __enter__JrzCancelScope.__enter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | NonecCr$rr%)rr-r/r1rrr__exit__MszCancelScope.__exit__N)rr rr!rr)rr )rr )rr rr)rr!)rr!rrrrr-r.r/r0r1r2rr3)rrr__doc__mathinfr#r(propertyrsetterr+rr,r4rrrrrs"       rFrrr!rcCstdttj|dS)z Open a cancel scope. :param shield: ``True`` to shield the cancel scope from external cancellation :return: a cancel scope .. deprecated:: 3.0 Use :class:`~CancelScope` directly. z?open_cancel_scope() is deprecated -- use CancelScope() directlyr<)rDeprecationWarningr rr<rrropen_cancel_scopeVs  r>c@s*eZdZdddZdddZdddZdS)FailAfterContextManager cancel_scopercCs ||_dSr) _cancel_scope)rr@rrr__init__i z FailAfterContextManager.__init__rcCs |jSr)rAr,r'rrrr,lrCz!FailAfterContextManager.__enter__r-r.r/r0r1r2r3cCs |j|||}|jjrt|Sr)rAr4r+ TimeoutError)rr-r/r1retvalrrrr4osz FailAfterContextManager.__exit__N)r@rr5r6)rrrrBr,r4rrrrr?hs  r?delay float | NonecCs4|dur t|ntj}tj||d}t|S)a Create a context manager which raises a :class:`TimeoutError` if does not finish in time. :param delay: maximum allowed time (in seconds) before raising the exception, or ``None`` to disable the timeout :param shield: ``True`` to shield the cancel scope from external cancellation :return: a context manager that yields a cancel scope :rtype: :class:`~typing.ContextManager`\[:class:`~anyio.CancelScope`\] Nr)r current_timer8r9rr?)rFrrr@rrr fail_after|s rIcCs,|dur t|ntj}tj||dS)aD Create a cancel scope with a deadline that expires after the given delay. :param delay: maximum allowed time (in seconds) before exiting the context block, or ``None`` to disable the timeout :param shield: ``True`` to shield the cancel scope from external cancellation :return: a cancel scope Nr)r rHr8r9r)rFrrrrr move_on_afters rJr cCstttS)a; Return the nearest deadline among all the cancel scopes effective for the current task. :return: a clock value from the event loop's internal clock (or ``float('inf')`` if there is no deadline in effect, or ``float('-inf')`` if the current scope has been cancelled) :rtype: float )r r current_effective_deadlinerrrrrKs rKrcCs tS)z: Create a task group. :return: a task group )r rrrrrcreate_task_groups rL)rr!rr)F)rFrGrr!rr?)rFrGrr!rr)rr )rr) __future__rr8typesrwarningsrZ abc._tasksrrZ_compatr r r Z _eventloopr rr ZTASK_STATUS_IGNOREDrr>r?rIrJrKrLrrrrs    >