o v&iS@sXdZddlZddlZddlmZddlmZmZmZm Z edZ Gdddej j Z dS)z]Minimal backported implementation of asyncio._PyTask from 3.11 compatible down to Python 3.8.N)AbstractEventLoop) CoroutineTypeVarAnyOptional_Tc seZdZdZddddeeeefdeedee ddffdd Z dd ee de fd d Z de fd dZde fddZZS)Taskz A coroutine wrapped in a Future.Nloopnamecoror r returncsd|_tj|||ddS)Nrr )_num_cancels_requestedsuper__init__)selfr r r  __class__d/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/backports/asyncio/runner/tasks.pyrsz Task.__init__msgcCspd|_|r dS|jd7_|jdur+tjdkr$|jj|dr#dSn|jr+dSd|_tjdkr6||_dS)aRequest that this task cancel itself. This arranges for a CancelledError to be thrown into the wrapped coroutine on the next cycle through the event loop. The coroutine then has a chance to clean up or even deny the request using try/except/finally. Unlike Future.cancel, this does not guarantee that the task will be cancelled: the exception might be caught and acted upon, delaying cancellation of the task or preventing cancellation completely. The task may also return a value or raise a different exception. Immediately after this method is called, Task.cancelled() will not return True (unless the task was already cancelled). A task will be marked as cancelled when the wrapped coroutine terminates with a CancelledError exception (even if cancel() was not called). This also increases the task's count of cancellation requests. FN) )rT) _log_tracebackdoner _fut_waitersys version_infocancel _must_cancel_cancel_message)rrrrrrs    z Task.cancelcCs|jS)zReturn the count of the task's cancellation requests. This count is incremented when .cancel() is called and may be decremented using .uncancel(). rrrrr cancellingLszTask.cancellingcCs|jdkr |jd8_|jS)zDecrement the task's count of cancellation requests. This should be called by the party that called `cancel()` on the task beforehand. Returns the remaining number of cancellation requests. rrr"r#rrruncancelTs z Task.uncancel)N)__name__ __module__ __qualname____doc__rrrrrstrrboolrintr$r% __classcell__rrrrrs   /r)r) asyncio.tasksasynciorrtypingrrrrrtasks_PyTaskrrrrrs