o hU @sddlmZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZddlmZejdkr:ddlmZnddlmZe rHdd lmZe d Ze d d d ZGdddeeZGdddedZdS)) annotationsN)ABCMetaabstractmethod) TracebackType) TYPE_CHECKINGAny AwaitableCallableTypeVaroverload)warn))Protocol) CancelScopeT_RetvalT_contraT) contravariantc@s4eZdZed ddZedd dZddd dZd S) TaskStatusselfTaskStatus[None]returnNonecCdSNrrrF/var/www/html/ai/venv/lib/python3.10/site-packages/anyio/abc/_tasks.pystartedzTaskStatus.startedvaluercCrrrrr rrrrrNT_contra | NonecCdS)zx Signal that the task has started. :param value: object passed back to the starter of the task Nrr!rrrr)rrrr)r rrrr)r r"rr)__name__ __module__ __qualname__r rrrrrrs   rc@sneZdZUdZded<dddd dZedddddZeddd ddZed!ddZ ed"ddZ dS)# TaskGroupz Groups several asynchronous tasks together. :ivar cancel_scope: the cancel scope inherited by all child tasks :vartype cancel_scope: CancelScope r cancel_scopeN)namefuncCallable[..., Awaitable[Any]]argsobjectr*rrcs(tdt|j|g|Rd|idS)a Start a new task in this task group. :param func: a coroutine function :param args: positional arguments to call the function with :param name: name of the task, for the purposes of introspection and debugging .. deprecated:: 3.0 Use :meth:`start_soon` instead. If your code needs AnyIO 2 compatibility, you can keep using this until AnyIO 4. zGspawn() is deprecated -- use start_soon() (without the "await") insteadr*N)r DeprecationWarning start_soonrr+r*r-rrrspawn0s zTaskGroup.spawncGr#)a Start a new task in this task group. :param func: a coroutine function :param args: positional arguments to call the function with :param name: name of the task, for the purposes of introspection and debugging .. versionadded:: 3.0 Nrr1rrrr0Hr$zTaskGroup.start_soonrcdS)a Start a new task and wait until it signals for readiness. :param func: a coroutine function :param args: positional arguments to call the function with :param name: name of the task, for the purposes of introspection and debugging :return: the value passed to ``task_status.started()`` :raises RuntimeError: if the task finishes without calling ``task_status.started()`` .. versionadded:: 3.0 Nrr1rrrstartYzTaskGroup.startcr3)z:Enter the task group context and allow starting new tasks.Nrrrrr __aenter__lr5zTaskGroup.__aenter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | Nonecr3)zrrrrr(&s  r() metaclass) __future__rsysabcrrtypesrtypingrrrr r r warningsr version_infortyping_extensionsanyio._core._tasksrrrrr(rrrrs