hjphddlZddlZgdZeZdZdej ddfdZdZd dZ d Z y) N) create_task decorate_taskget_number_of_pending_taskshandle_task_resulttaskc ttSN)len PENDING_TASKSK/DATA/.local/lib/python3.12/site-packages/trame_common/exec/asynchronous.pyrrs } r rreturnc |jy#tj$rYyt$rt j d|YywxYw)NzException raised by task = %r)resultasyncioCancelledError Exceptionlogging exceptionrs rrrsDA  ! !  A94@AsA A A ctj||jt|jtj|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 rrrs:d-.=001 Kr c| tj}t |j |S#t$r,tj}tj|YNwxYw)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-sa | )))+D )))4 55  )))+D  " "4 ( )s22A'&A'cfd}|S)z.wrapperFsD$)&)*r r )r'r(s` rrrCs+ Nr r ) rr__all__setr rTaskrrrrr r rr,sI  AW\\AdA"6,r