qidZddlZddlZddlZddlmZddlmZddlmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZdd lmZmZmZmZmZmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%dd l&m'Z'm(Z(m)Z)dd l*m+Z+dd l,m-Z-ddl.m/Z/GddeZ0e dee0ge dfZ1eGddZ2GddejfZ4dZ5Gdde/Z6y)zFrame processing pipeline infrastructure for Pipecat. This module provides the core frame processing system that enables building audio/video processing pipelines. It includes frame processors, pipeline management, and frame flow control mechanisms. N) dataclass)Enum) Any AwaitableCallable CoroutineListOptionalSequenceTupleType)logger)BaseInterruptionStrategy) BaseClock) CancelFrame ErrorFrameFrameFrameProcessorPauseFrameFrameProcessorPauseUrgentFrameFrameProcessorResumeFrameFrameProcessorResumeUrgentFrameInterruptionFrame StartFrame SystemFrameUninterruptibleFrame) LLMTokenUsage MetricsData) BaseObserverFrameProcessed FramePushed)FrameProcessorMetrics)BaseTaskManager) BaseObjectceZdZdZdZdZy)FrameDirectionzDirection of frame flow in the processing pipeline. Parameters: DOWNSTREAM: Frames flowing from input to output. UPSTREAM: Frames flowing back from output to input. N)__name__ __module__ __qualname____doc__ DOWNSTREAMUPSTREAMT/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/processors/frame_processor.pyr%r%7sJHr/r%FrameProcessorc:eZdZUdZeed<eed<dZee ed<y)FrameProcessorSetupaConfiguration parameters for frame processor initialization. Parameters: clock: The clock instance for timing operations. task_manager: The task manager for handling async operations. observer: Optional observer for monitoring frame processing events. clock task_managerNobserver) r(r)r*r+r__annotations__r"r6r rr.r/r0r3r3Fs$ !!'+Hh|$+r/r3cVeZdZdZdZdZfdZdeee e fffd Z de ffd Z xZS) FrameProcessorQueuea A priority queue for systems frames and other frames. This is a specialized queue for frame processors that separates and prioritizes system frames over other frames. It ensures that `SystemFrame` objects are processed before any other frames by using a priority queue. r&r'c>t|d|_d|_y)z#Initialize the FrameProcessorQueue.rN)super__init__"_FrameProcessorQueue__high_counter!_FrameProcessorQueue__low_counterself __class__s r0r<zFrameProcessorQueue.__init__as r/itemcPK|\}}}t|trD|xjdz c_t||j |j|fd{y|xj dz c_t||j|j |fd{y7I7w)a8Put an item into the priority queue. System frames (`SystemFrame`) have higher priority than any other frames. If a non-frame item (e.g. a watchdog cancellation sentinel) is provided it will have the highest priority. Args: item (Any): The item to enqueue. r&N) isinstancerr=r;put HIGH_PRIORITYr> LOW_PRIORITY)r@rBframe_rAs r0rEzFrameProcessorQueue.putgs q! e[ )   1 $ '+t1143F3FMN N N   ! # '+t00$2D2DdKL L L O Ms%AB&B"AB&B$B&$B&returncHKt|d{\}}}|S7 w)zRetrieve the next item from the queue. System frames are prioritized. If both queues are empty, this method waits until an item is available. Returns: Any: The next item from the system or main queue. N)r;get)r@rIrBrAs r0rLzFrameProcessorQueue.getzs'!7;=( 1d )s "  ")r(r)r*r+rFrGr<r rr% FrameCallbackrErrL __classcell__rAs@r0r9r9UsDML MeE>=$HIM& 3  r/r9c\eZdZdZdddddeededeeffdZe d e fd Z e d efd Z e d e dfd Ze d e dfd Ze d edfdZe d edfdZe dZe dZe dZe dZe d eefdZe d efdZdZd efdZdefdZdddeefdZ dddeefdZ!dddeefd Z"dddeefd!Z#d"e$fd#Z%d$efd%Z&d&Z'd'Z(d(Z)d\d)e*deed e+jXfd*Z-d]d+e+jXd,eefd-Z.d\d+e+jXd,eefd.Z/d/e0fd0Z1fd1Z2d^d2Z3d e4fd3Z5d e+jlfd4Z7e8jrdfd5e:d6e8d7ee;fd8Zd;Z?d<Z@d5e:d6e8fd=ZA d_d>ed?eeBd@efdAZCdBeDfdCZEe8jrfd5e:d6e8fdDZFdEZGdFdGd,efdHZHdIeIe:fdJZJd5e:fdKZKd5eLfdLZMd5eNfdMZOd5ePeQzfdNZRd5eSeTzfdOZUdPZVd5e:d6e8fdQZWd5e:fdRZXdSZYdTZZdUZ[dVZ\dWZ]dXZ^d5e:d6e8d7ee;fdYZ_dZZ`d[ZaxZbS)`r1a6Base class for all frame processors in the pipeline. Frame processors are the building blocks of Pipecat pipelines, they can be linked to form complex processing pipelines. They receive frames, process them, and pass them to the next or previous processor in the chain. Each frame processor guarantees frame ordering and processes frames in its own task. System frames are also processed in a separate task which guarantees frame priority. Event handlers available: - on_before_process_frame: Called before a frame is processed - on_after_process_frame: Called after a frame is processed - on_before_push_frame: Called before a frame is pushed - on_after_push_frame: Called after a frame is pushed - on_error: Called when an error is raised in the frame processing. NF)nameenable_direct_modemetricsrRrSrTc t|d d|i|d|_d|_||_d|_d|_d|_d|_d|_ d|_ d|_ g|_ d|_ d|_d|_|xs t!|_|j"j%|j&d|_t+|_d|_d|_d|_t5j6|_d|_d|_d|_|jAdd|jAdd|jAdd|jAd d|jAd dy) aYInitialize the frame processor. Args: name: Optional name for this processor instance. enable_direct_mode: Whether to process frames immediately or use internal queues. metrics: Optional metrics collector for this processor. **kwargs: Additional arguments passed to parent class. rRNFon_before_process_frameT)syncon_after_process_frameon_before_push_frameon_after_push_frameon_errorr.)!r;r<_prev_next_enable_direct_mode_clock _task_manager _observer_enable_metrics_enable_usage_metrics_report_only_initial_ttfb_allow_interruptions_interruption_strategies_deprecated_openaillmcontext_FrameProcessor__started _cancellingr!_metricsset_processor_namerR+_FrameProcessor__should_block_system_framesr9_FrameProcessor__input_queue_FrameProcessor__input_event!_FrameProcessor__input_frame_task$_FrameProcessor__should_block_framesasyncioQueue_FrameProcessor__process_queue_FrameProcessor__process_event#_FrameProcessor__process_frame_task&_FrameProcessor__process_current_frame_register_event_handler)r@rRrSrTkwargsrAs r0r<zFrameProcessor.__init__su -d-f-15 15 $6 ,0 9=26 %%*").&$)!HJ%,1)! :#8#:  ((3-2)026::>&+"&}}8<<@!8<$ $$%>T$J $$%=D$I $$%;$$G $$%:$F $$Zd$;r/rJc|jS)z}Get the unique identifier for this processor. Returns: The unique integer ID of this processor. )_idr@s r0idzFrameProcessor.ids xxr/c|jS)zkGet the name of this processor. Returns: The name of this processor instance. )_namer{s r0rRzFrameProcessor.namezzr/cgS)a?Return the list of sub-processors contained within this processor. Only compound processors (e.g. pipelines and parallel pipelines) have sub-processors. Non-compound processors will return an empty list. Returns: The list of sub-processors if this is a compound processor. r.r{s r0 processorszFrameProcessor.processors s  r/cgS)aReturn the list of entry processors for this processor. Entry processors are the first processors in a compound processor (e.g. pipelines, parallel pipelines). Note that pipelines can also be an entry processor as pipelines are processors themselves. Non-compound processors will simply return an empty list. Returns: The list of entry processors. r.r{s r0entry_processorszFrameProcessor.entry_processorss  r/c|jS)zxGet the next processor. Returns: The next processor, or None if there's no next processor. )r]r{s r0nextzFrameProcessor.next%rr/c|jS)zGet the previous processor. Returns: The previous processor, or None if there's no previous processor. )r\r{s r0previouszFrameProcessor.previous.rr/cddl}|j5|jd|jdtdddd|j S#1swY|j SxYw)zCheck if interruptions are allowed for this processor. .. deprecated:: 0.0.99 Use `LLMUserAggregator`'s new `user_mute_strategies` parameter instead. Returns: True if interruptions are allowed. rNalwaysz}`FrameProcessor.interruptions_allowed` is deprecated. Use `LLMUserAggregator`'s new `user_mute_strategies` parameter instead.r' stacklevel)warningscatch_warnings simplefilterwarnDeprecationWarningre)r@rs r0interruptions_allowedz$FrameProcessor.interruptions_allowed7sj   $ $ &   ! !( + MMZ"   ((( (((s *AA'c|jS)zuCheck if metrics collection is enabled. Returns: True if metrics collection is enabled. )rbr{s r0metrics_enabledzFrameProcessor.metrics_enabledNs###r/c|jS)zCheck if usage metrics collection is enabled. Returns: True if usage metrics collection is enabled. )rcr{s r0usage_metrics_enabledz$FrameProcessor.usage_metrics_enabledWs)))r/c|jS)zCheck if only initial TTFB should be reported. Returns: True if only initial time-to-first-byte should be reported. )rdr{s r0report_only_initial_ttfbz'FrameProcessor.report_only_initial_ttfb`s---r/c|jS)a Get the interruption strategies for this processor. .. deprecated:: 0.0.99 This function is deprecated, use the new user and bot turn start strategies insted. Returns: Sequence of interruption strategies. )rfr{s r0interruption_strategiesz&FrameProcessor.interruption_strategiesis,,,r/cN|jst|d|jS)zGet the task manager for this processor. Returns: The task manager instance. Raises: Exception: If the task manager is not initialized. z& TaskManager is still not initialized.)r` Exceptionr{s r0r5zFrameProcessor.task_managervs,!!tf$JKL L!!!r/cgS)aReturn processors that can generate metrics. Recursively collects all processors that support metrics generation, including those from nested processors. Returns: List of frame processors that can generate metrics. r.r{s r0processors_with_metricsz&FrameProcessor.processors_with_metricss  r/cy)zCheck if this processor can generate metrics. Returns: True if this processor can generate metrics. Fr.r{s r0can_generate_metricsz#FrameProcessor.can_generate_metricss r/datac:|jj|y)zlSet core metrics data for this processor. Args: data: The metrics data to set. N)rjset_core_metrics_data)r@rs r0rz$FrameProcessor.set_core_metrics_datas ++D1r/ start_timercK|jr=|jr0|jj||jd{yyy7w)zStart time-to-first-byte metrics collection. Args: start_time: Optional timestamp to use as the start time. If None, uses the current time. )rrN)rrrjstart_ttfb_metricsrdr@rs r0rz!FrameProcessor.start_ttfb_metricssV  $ $ &4+?+?--22%@^@^3  ,@ & sAA A Aend_timercK|jrN|jrA|jj|d{}|r|j |d{yyyy7#7 w)zStop time-to-first-byte metrics collection and push results. Args: end_time: Optional timestamp to use as the end time. If None, uses the current time. rN)rrrjstop_ttfb_metrics push_framer@rrHs r0rz FrameProcessor.stop_ttfb_metricss`  $ $ &4+?+?--9989LLEooe,,,,@ &L,!>@ @ @,@ & @s:AAAcK|jrL|jr?|jjd{}|r|j |d{yyyy7#7 w)z?Stop text aggregation time metrics collection and push results.N)rrrjstop_text_aggregation_metricsrr@rHs r0rz,FrameProcessor.stop_text_aggregation_metricssY  $ $ &4+?+?--EEGGEooe,,,,@ &G,s!:A$A A$A" A$"A$cK|jd{|jd{|jd{y7577 w)z#Stop all active metrics collection.N)rrrr{s r0stop_all_metricszFrameProcessor.stop_all_metricssI$$&&&**,,,00222 ',2s1AA AAAAAAA coroutinec|r|d|}n|d|jj}|jj||S)zCreate a new task managed by this processor. Args: coroutine: The coroutine to run in the task. name: Optional name for the task. Returns: The created asyncio task. z::)cr_codeco_namer5 create_task)r@rrRs r0rzFrameProcessor.create_tasksM V2dV$DV2i//7789D  ,,Y==r/tasktimeoutcXK|jj||d{y7w)aICancel a task managed by this processor. A default timeout if 1 second is used in order to avoid potential freezes caused by certain libraries that swallow `asyncio.CancelledError`. Args: task: The task to cancel. timeout: Optional timeout for task cancellation. N)r5 cancel_task)r@rrs r0rzFrameProcessor.cancel_tasks$++D':::s *(*cKddl}|j5|jd|jdtdddd|rt j ||d{y|d{y#1swY5xYw77w)a)Wait for a task to complete. .. deprecated:: 0.0.81 This function is deprecated, use `await task` or `await asyncio.wait_for(task, timeout)` instead. Args: task: The task to wait for. timeout: Optional timeout for waiting. rNrzt`FrameProcessor.wait_for_task()` is deprecated. Use `await task` or `await asyncio.wait_for(task, timeout)` instead.r'r)rrrrrrqwait_for)r@rrrs r0 wait_for_taskzFrameProcessor.wait_for_tasks   $ $ &   ! !( + MMW"    ""41 1 1JJ   2 s:B*A5#B$B% B/B0B5A>:BBsetupc K|j|_|j|_|j|_|j |j.|jj|jd{yy7w)zSet up the processor with required components. Args: setup: Configuration object containing setup parameters. N) r4r_r5r`r6ra"_FrameProcessor__create_input_taskrjr)r@rs r0rzFrameProcessor.setup-sj kk "//   " == $--%%d&8&89 9 9 % 9sA8B:B;BcKt|d{|jd{|jd{|j#|jjd{yy7d7N787 w)zClean up processor resources.N)r;cleanup"_FrameProcessor__cancel_input_task$_FrameProcessor__cancel_process_taskrjr?s r0rzFrameProcessor.cleanup=sqgo&&(((((*** == $--'') ) ) % (* )sCBA:BA<BA>-B3B4B<B>BBcj||_||_tjd|d|jy)zLink this processor to the next processor in the pipeline. Args: processor: The processor to link to. zLinking z -> N)r]r\rdebug)r@ processors r0linkzFrameProcessor.linkEs/    xvT$**67r/cN|jst|d|jS)zGet the clock used by this processor. Returns: The clock instance. Raises: Exception: If the clock is not initialized. z Clock is still not initialized.)r_rr{s r0 get_clockzFrameProcessor.get_clockOs({{tf$DEF F{{r/c6|jjS)ziGet the event loop used by this processor. Returns: The asyncio event loop. )r5get_event_loopr{s r0rzFrameProcessor.get_event_loop\s   //11r/rH directioncallbackcK|jry|jr|j|||d{y|jj |||fd{y7,7w)zQueue a frame for processing. Args: frame: The frame to queue. direction: The direction of frame flow. callback: Optional callback to call after processing. N)rir^_FrameProcessor__process_framermrEr@rHrrs r0 queue_framezFrameProcessor.queue_frameds`      # #&&uiB B B$$((%H)EF F F C Fs!0A#A&A#A!A#!A#cKtj|dd|_|jr|jj yyw)z"Pause processing of queued frames.z: pausing frame processingTN)rtracerprtclearr{s r0pause_processing_framesz&FrameProcessor.pause_processing_frameszsB v789%)"     & & ( AA cKtj|dd|_|jr|jj yyw)z)Pause processing of queued system frames.z!: pausing system frame processingTN)rrrlrnrr{s r0pause_processing_system_framesz-FrameProcessor.pause_processing_system_framessB v>?@,0)       $ $ & rcKtj|d|jr|jjyyw)z#Resume processing of queued frames.z: resuming frame processingN)rrrtsetr{s r0resume_processing_framesz'FrameProcessor.resume_processing_framess: v89:     $ $ & AAcKtj|d|jr|jjyyw)z*Resume processing of queued system frames.z": resuming system frame processingN)rrrnrr{s r0resume_processing_system_framesz.FrameProcessor.resume_processing_system_framess: v?@A       " " $ rcK|jrZ|jr|jjnd}t||||}|jj |d{t |t r|j|d{yt |tr1|jd{|jd{yt |tr|j|d{yt |ttfr|j|d{yt |t t"fr|j%|d{yy77777n7@7w)zProcess a frame. Args: frame: The frame to process. direction: The direction of frame flow. r)rrHr timestampN)rar_get_timeron_process_framerDr_FrameProcessor__startr_start_interruptionrr_FrameProcessor__cancelrr_FrameProcessor__pauserr_FrameProcessor__resume)r@rHrrrs r0 process_framezFrameProcessor.process_frames+ >>26++ ,,.1I!## D ..11$7 7 7 eZ (,,u% % % 0 1**, , ,'') ) ) { +--& & &  8:XY Z,,u% % %  9;Z[ \--& & &] 8 & , ) & % &s~A"E-$E%(E- E!(E-6E#7E-E%)E-8E'9/E-(E))/E-E+E-!E-#E-%E-'E-)E-+E- error_msg exceptionfatalcbKt||||}|j|d{y7w)aCreates and pushes an ErrorFrame upstream. Creates and pushes an ErrorFrame upstream to notify other processors in the pipeline about an error condition. The error frame will include context about which processor generated the error. Args: error_msg: Descriptive message explaining the error condition. exception: Optional exception object that caused the error, if available. This provides additional context for debugging and error handling. fatal: Whether this error should be considered fatal to the pipeline. Fatal errors typically cause the entire pipeline to stop processing. Defaults to False for non-fatal errors. Example:: ```python # Non-fatal error await self.push_error("Failed to process audio chunk, skipping") # Fatal error with exception context try: result = some_critical_operation() except Exception as e: await self.push_error("Critical operation failed", exception=e, fatal=True) ``` )errorrrr)rN)rpush_error_frame)r@rrr error_frames r0 push_errorzFrameProcessor.push_errors1B!y^bc ##+#666s %/-/rcK|js||_|jd|d{|jrdtj|jj }|d}|jd|j d|jd|j}n|jd|j}tj||j|tjd{y77w)zaPush an error frame upstream. Args: error: The error frame to push. r[Nz exception (:z): z error: ) r_call_event_handlerr traceback extract_tb __traceback__filenamelinenorrrr%r-)r@rtblast error_messages r0rzFrameProcessor.push_error_frames "EO&&z5999 ??%%eoo&C&CDBb6D??#< a }CPUP[P[}]  %/x }EM ]#ooe^%<%<=== : >s")C=C9CC=3C;4C=;C=cK|j|sy|jd|d{|j||d{|jd|d{y797!7 w)zPush a frame to the next processor in the pipeline. Args: frame: The frame to push. direction: The direction to push the frame. NrYrZ)_check_startedr$_FrameProcessor__internal_push_frame)r@rHrs r0rzFrameProcessor.push_framesk""5) &&'=uEEE(( :::&&'Broadcast an `InterruptionFrame` both upstream and downstream.z: broadcasting interruptionN)rr#_FrameProcessor__reset_process_taskrbroadcast_framerr{s r0broadcast_interruptionz%FrameProcessor.broadcast_interruptionsV v89: !!###%%%""#4555 &5s!0A0A-.>.A.A+oo.///oonn.E.EFFF 0Fs$AA; A7 'A;1A92A;9A;c Kt|}tj|Dcic]0}|js|jt ||j2}}tj|Dcic]=}|js/|jdvr!|jt ||j?}}|di|}|j D]\}}t||||di|} |j D]\}}t| ||| j|_ |j| _ |j|d{|j| tjd{ycc}wcc}w777w)aBroadcasts a frame instance upstream and downstream. This method creates two new frame instances shallow-copying all fields from the original frame except `id` and `name`, which get fresh values. Args: frame: The frame instance to broadcast. Note: Prefer using `broadcast_frame()` when possible, as it is more efficient. This method should only be used when you are not the creator of the frame and need to broadcast an existing instance. )r|rRNr.) type dataclassesfieldsinitrRgetattritemssetattrr|rrr%r-) r@rHrf init_fields extra_fieldsrkvrs r0broadcast_frame_instancez'FrameProcessor.broadcast_frame_instance(smK ?J?Q?QRW?Xc!\]\b\bqvvwuaff55c c!''. 66affN: FFGE166* *  %3{3 &&( ,DAq $a + ,#1[1 &&( *DAq NAq ) *1?0A0A-.>.A.A+oo.///oonn.E.EFFF%d 0FsA#FE5#E5F3AE:5BFE?'F/F0FFc Kd|_|j|_|j|_|j |_|j|_|j|_ d|jv|_ |jyw)zHandle the start frame to initialize processor state. Args: frame: The start frame containing initialization parameters. Tdeprecated_openaillmcontextN)rhallow_interruptionsreenable_metricsrbenable_usage_metricsrcrrfrrdmetadatarg$_FrameProcessor__create_process_taskrs r0__startzFrameProcessor.__startKsu $)$=$=!$33%*%?%?"(-(E(E%).)G)G&-JU^^,[) ""$sBBcNKd|_|jd{y7w)zqHandle the cancel frame to stop processor operation. Args: frame: The cancel frame. TN)rirrs r0__cancelzFrameProcessor.__cancel]s"  ((***s %#%cK|jj|jk(r|jd{yy7w)zlHandle pause frame to pause processor operation. Args: frame: The pause frame. N)rrRrrs r0__pausezFrameProcessor.__pausefs8 ??  499 ,..0 0 0 - 07AAAcK|jj|jk(r|jd{yy7w)zoHandle resume frame to resume processor operation. Args: frame: The resume frame. N)rrRrrs r0__resumezFrameProcessor.__resumeos8 ??  499 ,//1 1 1 - 1r5c"K t|jtr|jy|j d{|j y7#t $r)}|jd||d{7Yd}~yd}~wwxYww)z;Start handling an interruption by cancelling current tasks.Nz1Uncaught exception handling _start_interruption: rr)rDrvr$_FrameProcessor__reset_process_queuerr/rr)r@es r0rz"FrameProcessor._start_interruption|s $668LM**,00222**,3 //MaSQ"   sVB*ABAAABA B #B<A?=BBB  BcK |jr|jjnd}|tjk(r|jrt j d|d|d|j|jr=t||j|||}|jj|d{|jj||d{y|tjk(r|jrt j d|d|d|j|jr=t||j|||}|jj|d{|jj||d{yyy777/7 #t$r)}|jd|| d{7Yd}~yd}~wwxYww) zInternal method to push frames to adjacent processors. Args: frame: The frame to push. direction: The direction to push the frame. rzPushing z downstream from z to )source destinationrHrrNz upstream from zUncaught exception: r9)r_rr%r,r]rrrar on_push_framerr-r\rr)r@rHrrrr;s r0__internal_push_framez$FrameProcessor.__internal_push_frames U26++ ,,.1IN555$** xw.?vT$**VW>>&#$(JJ#"+"+ D..66t<<<jj,,UI>>>n555$** xwodV4 |TU>>&#$(JJ#"+"+ D..66t<<<jj,,UI>>>;E5=>=> U//.B1#,FRS/T T T UsGB3F 7F8#F FF G!B F ,F-#F FF GF F F F G)G GG G GGch|jstj|d|d|jS)zCheck if the processor has been started. Args: frame: The frame being processed. Returns: True if the processor has been started. z Trying to process z but StartFrame not received yet)rhrrrs r0rzFrameProcessor._check_starteds0~~ LLD6!4UG;[\ ]~~r/c|jry|js>tj|_|j |j |_yy)z'Create the frame input processing task.N)r^rorqEventrnr)_FrameProcessor__input_frame_task_handlerr{s r0__create_input_taskz"FrameProcessor.__create_input_tasksF  # # &&!(D &*&6&6t7V7V7X&YD #'r/cK|jr0|j|jtd{d|_yy7 w)z'Cancel the frame input processing task.N)rorINPUT_TASK_CANCEL_TIMEOUT_SECSr{s r0__cancel_input_taskz"FrameProcessor.__cancel_input_tasksA  " """4#:#:?@**//111$$**,-2* v%?@A&&uiB B B  * * ,!,L 2 Cs5&C?C9AC?C;AC?C= C?;C?=C?)N)g?)rr1)NF)cr(r)r*r+r strboolr!r<propertyintr|rRr rrrrrrrrr rrr"r5rrrrfloatrrrrrrrrrrrrqTaskrrrr3rrrrrAbstractEventLooprr%r,rrMrrrrrrrrrrrrrr rr(rrrrrrrrrrrrrrrr/rr:rrrDrJrNrOs@r0r1r1sh*##(37 W<smW<! W< /0 WY>hsm>w||> ;gll ;Xe_ ; x6:!4: *8 9 2 9 92%3$=$=,0 GG"G=) G,)'' % ''>'@*. "7"7I&"7 "7H>J>,JXIbIbEeEE 6OR,e,(GtE{G$!GE!GF%:%$+K+1#;>\#\12$=@_$_2"#U#U>#UJ E Z+^%"&- YY'5YAI-AXY +8-r/)7r+rqrrrenumrtypingrrrrr r r r r logurur6pipecat.audio.interruptions.base_interruption_strategyrpipecat.clocks.base_clockrpipecat.frames.framesrrrrrrrrrrrpipecat.metrics.metricsrrpipecat.observers.base_observerrrr 2pipecat.processors.metrics.frame_processor_metricsr!"pipecat.utils.asyncio.task_managerr"pipecat.utils.base_objectr#r%rMr3 PriorityQueuer9rGr1r.r/r0rrs!   [/    ?UUT>0 T *E>BIdOST   , ,  ,0'//0j"#m-Zm-r/