@gU ddlmZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZddlmZejdkrddlmZnddlmZe rdd lmZe d Ze d d ZGddeeZGddeZdS)) annotationsN)ABCMetaabstractmethod) TracebackType) TYPE_CHECKINGAny AwaitableCallableTypeVaroverload)warn))Protocol) CancelScopeT_RetvalT_contraT) contravariantcHeZdZed dZed dZddd Zd S) TaskStatusselfTaskStatus[None]returnNonecdSNrs D/var/www/piapp/venv/lib/python3.11/site-packages/anyio/abc/_tasks.pystartedzTaskStatus.started valuercdSrrrr#s rr zTaskStatus.startedr!r"NT_contra | NonecdS)zx Signal that the task has started. :param value: object passed back to the starter of the task Nrr%s rr zTaskStatus.startedr")rrrr)r#rrrr)r#r&rr)__name__ __module__ __qualname__r r rr"rrrsk    X    X        r"rceZdZUdZded<dddd ZeddddZeddddZeddZ eddZ 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/rrcVKtdt|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_soonrr0r/r2s rspawnzTaskGroup.spawn0sJ$ U     /t///$/////r"cdS)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 Nrr7s rr6zTaskGroup.start_soonHr(r"rc KdS)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 Nrr7s rstartzTaskGroup.startY r"c KdS)z:Enter the task group context and allow starting new tasks.Nrrs r __aenter__zTaskGroup.__aenter__lr<r"exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | Nonec KdS)zrGrr"rr-r-&s  0000000       ^        ^ $III^IKKK^KKKr"r-) metaclass) __future__rsysabcrrtypesrtypingrrr r r r warningsr version_infortyping_extensionsanyio._core._tasksrrrrr-rr"rrTs|"""""" ''''''''MMMMMMMMMMMMMMMMv******/...... 7:   7:T 2 2 2     (#   "QKQKQKQKQK'QKQKQKQKQKQKr"