o i@sdZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z ddl mZeGdddZGd d d eZeGd d d ZGd ddeZdS)zAsyncio task management. This module provides task management functionality. Includes both abstract base classes and concrete implementations for managing asyncio tasks with comprehensive monitoring and cleanup capabilities. N)ABCabstractmethod) dataclass) CoroutineDictOptionalSequence)loggerc@eZdZUdZejed<dS)TaskManagerParamszConfiguration parameters for task manager initialization. Parameters: loop: The asyncio event loop to use for task management. loopN)__name__ __module__ __qualname____doc__asyncioAbstractEventLoop__annotations__rrV/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/utils/asyncio/task_manager.pyr  r c@seZdZdZedefddZedejfddZ ede d e dej fd d Z edd ej deefddZedeej fddZd S)BaseTaskManagerzAbstract base class for asyncio task management. Provides the interface for creating, monitoring, and managing asyncio tasks. paramscCdSzInitialize the task manager with configuration parameters. Args: params: Configuration parameters for task management. Nrselfrrrrsetup(zBaseTaskManager.setupreturncCr)zuGet the event loop used by this task manager. Returns: The asyncio event loop instance. Nrrrrrget_event_loop1rzBaseTaskManager.get_event_loop coroutinenamecCr)a]Creates and schedules a new asyncio Task that runs the given coroutine. The task is added to a global set of created tasks. Args: coroutine: The coroutine to be executed within the task. name: The name to assign to the task for identification. Returns: The created task object. Nr)rr"r#rrr create_task:s zBaseTaskManager.create_taskNtasktimeoutcsdS)XCancels the given asyncio Task and awaits its completion with an optional timeout. This function removes the task from the set of registered tasks upon completion or failure. Args: task: The task to be cancelled. timeout: The optional timeout in seconds to wait for the task to cancel. Nr)rr%r&rrr cancel_taskIs zBaseTaskManager.cancel_taskcCr)Returns the list of currently created/registered tasks. Returns: Sequence of currently managed asyncio tasks. Nrr rrr current_tasksVrzBaseTaskManager.current_tasksN)r rrrrr rrrr!rstrTaskr$rfloatr(rr*rrrrr"s rc@r )TaskDatazwInternal data structure for tracking task metadata. Parameters: task: The asyncio Task being managed. r%N)r rrrrr-rrrrrr/`rr/c@seZdZdZdddZdefddZdejfd d Z d e d e dej fd dZ ddej deefddZdeej fddZdefddZdej fddZdS) TaskManagerzConcrete implementation of BaseTaskManager. Manages asyncio tasks. Provides comprehensive task lifecycle management including creation, monitoring, cancellation, and cleanup. rNcCsi|_d|_dS)z5Initialize the task manager with empty task registry.N)_tasks_paramsr rrr__init__ss zTaskManager.__init__rcCs|js||_dSdSr)r2rrrrrxs zTaskManager.setupcCs|jstd|jjS)zGet the event loop used by this task manager. Returns: The asyncio event loop instance. Raises: Exception: If the task manager is not properly set up. 2TaskManager is not setup: unable to get event loop)r2 Exceptionr r rrrr!s zTaskManager.get_event_loopr"r#csffdd}|jstd|jj|}|||j|t|dt d|S)aCreates and schedules a new asyncio Task that runs the given coroutine. The task is added to a global set of created tasks. Args: coroutine: The coroutine to be executed within the task. name: The name to assign to the task for identification. Returns: The created task object. Raises: Exception: If the task manager is not properly set up. c szIdHWStjytdtyF}z#t|j}|d}td|j d|j d|WYd}~dSd}~ww)Nz: task cancelledz unexpected exception (:): ) rCancelledErrorr tracer5 traceback extract_tb __traceback__errorfilenamelineno)etblastr"r#rr run_coroutines  2z.TaskManager.create_task..run_coroutiner4r%z: task created) r2r5r r$set_nameadd_done_callback_task_done_handler _add_taskr/r r:)rr"r#rEr%rrDrr$s   zTaskManager.create_taskr%r&c s(|}|z|rtj||dIdHWdS|IdHWdStjy3t|dYdStjy=YdStyk}z#t |j }|d}t |d|j d|jd|WYd}~dSd}~wty}zt |j }|d}t|d|j d|jd|d}~ww) r')r&Nz&: timed out waiting for task to cancelr6z- unexpected exception while cancelling task (r7r8z- fatal base exception while cancelling task ()get_namecancelrwait_for TimeoutErrorr warningr9r5r;r<r=r>r?r@ BaseExceptioncritical)rr%r&r#rArBrCrrrr(s6   zTaskManager.cancel_taskcCsdd|jDS)r)cSsg|]}|jqSrrF).0datarrr sz-TaskManager.current_tasks..)r1valuesr rrrr*szTaskManager.current_tasks task_datacCs|j}||j|<dS)zfAdd a task to the internal registry. Args: task_data: The task metadata. N)r%rKr1)rrVr#rrrrJs zTaskManager._add_taskc CsR|}z|j|=WdSty(}zt|d|WYd}~dSd}~ww)zHandle task completion by removing the task from the registry. Args: task: The completed asyncio task. z1: unable to remove task data (already removed?): N)rKr1KeyErrorr r:)rr%r#rArrrrIs"zTaskManager._task_done_handler)rNr+)r rrrr3r rrrr!rr,r-r$rr.r(rr*r/rJrIrrrrr0ks   &$ r0)rrr;abcrr dataclassesrtypingrrrrlogurur r rr/r0rrrrs   >