qidZddlmZddlmZddlmZddlmZerddl m Z m Z eGddZ eGd d Z Gd d eZy )a$Base observer classes for monitoring frame flow in the Pipecat pipeline. This module provides the foundation for observing frame transfers between processors without modifying the pipeline structure. Observers can be used for logging, debugging, analytics, and monitoring pipeline behavior. ) dataclass) TYPE_CHECKING)Frame) BaseObject)FrameDirectionFrameProcessorc:eZdZUdZded<eed<ded<eed<y) FrameProcesseda/Event data for frame processing in the pipeline. Represents an event where a frame is being processed by a processor. This data structure is typically used by observers to track the flow of frames through the pipeline for logging, debugging, or analytics purposes. Parameters: processor: The processor processing the frame. frame: The frame being processed. direction: The direction of the frame (e.g., downstream or upstream). timestamp: The time when the frame was pushed, based on the pipeline clock. r processorframer direction timestampN__name__ __module__ __qualname____doc____annotations__rintQ/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/observers/base_observer.pyr r s   LNrr cDeZdZUdZded<ded<eed<ded<eed<y ) FramePushedaEvent data for frame transfers between processors in the pipeline. Represents an event where a frame is pushed from one processor to another within the pipeline. This data structure is typically used by observers to track the flow of frames through the pipeline for logging, debugging, or analytics purposes. Parameters: source: The processor sending the frame. destination: The processor receiving the frame. frame: The frame being transferred. direction: The direction of the transfer (e.g., downstream or upstream). timestamp: The time when the frame was pushed, based on the pipeline clock. rsource destinationr rr rNrrrrrr/s%  !! LNrrc.eZdZdZdefdZdefdZdZy) BaseObserveraBBase class for pipeline frame observers. Observers can view all frames that flow through the pipeline without needing to inject processors into the pipeline structure. This enables non-intrusive monitoring capabilities such as frame logging, debugging, performance analysis, and analytics collection. datac Kyw)adHandle the event when a frame is being processed by a processor. This method should be implemented by subclasses to define specific behavior (e.g., logging, monitoring, debugging) when a frame is being processed by a processor. Args: data: The event data containing details about the frame processing. Nrselfrs ron_process_framezBaseObserver.on_process_frameP  c Kyw)ajHandle the event when a frame is pushed from one processor to another. This method should be implemented by subclasses to define specific behavior (e.g., logging, monitoring, debugging) when a frame is transferred through the pipeline. Args: data: The event data containing details about the frame transfer. Nrr!s r on_push_framezBaseObserver.on_push_frame\r$r%c Kyw)zCalled when the pipeline has fully started. Fired after the ``StartFrame`` has been processed by all processors in the pipeline, including nested ``ParallelPipeline`` branches. Nr)r"s ron_pipeline_startedz BaseObserver.on_pipeline_startedhs r%N) rrrrr r#rr'r)rrrrrGs$  >      rrN)r dataclassesrtyping_extensionsrpipecat.frames.framesrpipecat.utils.base_objectr"pipecat.processors.frame_processorrrr rrrrrr/s\"+'0Q  *  .' :' r