'jpfddlZddlZgdZeZdZdejddfdZdZd dZ d Z dS) N) create_task decorate_taskget_number_of_pending_taskshandle_task_resulttaskc*ttSN)len PENDING_TASKSX/DATA/AppData/hermes/venv/lib/python3.11/site-packages/trame_common/exec/asynchronous.pyrrs }  r rreturnc |dS#tj$rYdSt$rt jd|YdSwxYw)NzException raised by task = %r)resultasyncioCancelledError Exceptionlogging exceptionrs rrrsqA  !     AAA94@@@@@@AsA A  A ct||t|tj|S)a  Decorate a task by attaching a done callback so any exception or error could be caught and reported. :param task: A coroutine to execute as an independent task :type task: asyncio.Task :return: The same task object :rtype: asyncio.Task )r addadd_done_callbackrdiscardrs rrrsId-...=0111 Kr c|L tj}n7#t$r*tj}tj|YnwxYwt ||S)a Create a task from a coroutine while also attaching a done callback so any exception or error could be caught and reported. :param coroutine: A coroutine to execute as an independent task :param loop: Optionally provide the loop on which the task should be scheduled on. By default we will use the current running loop. :return: The decorated task :rtype: asyncio.Task )rget_event_loop RuntimeErrornew_event_loopset_event_looprr) coroutineloops rrr-s| | ))++DD ) ) ))++D  "4 ( ( ( ( ( ) )))44 5 55s1A  A cfd}|S)z.wrapperFs&DD$)&))*****r r )r'r(s` rrrCs#+++++ Nr r ) rr__all__setr rTaskrrrrr r rr,s    AW\AdAAAA"6666,r