o i@sdZddlmZmZddlmZmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZddlmZGd d d eZGd d d eZd S)zDebug logging observer for frame activity monitoring. This module provides a debug observer that logs detailed frame activity to the console, making it useful for debugging pipeline behavior and understanding frame flow between processors. )fields is_dataclass)Enumauto)DictOptionalSetTupleTypeUnion)logger)Frame) BaseObserver FramePushed)FrameDirectionc@seZdZdZeZeZdS) FrameEndpointzSpecifies which endpoint (source or destination) to filter on. Parameters: SOURCE: Filter on the source component that is pushing the frame. DESTINATION: Filter on the destination component receiving the frame. N)__name__ __module__ __qualname____doc__rSOURCE DESTINATIONrr`/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/observers/loggers/debug_log_observer.pyrs rc seZdZdZ  ddeeeeedfe eeeeee fffdee e ffdd Z dd Zd d Zd efd dZZS)DebugLogObserveramObserver that logs frame activity with detailed content to the console. Automatically extracts and formats data from any frame type, making it useful for debugging pipeline behavior without needing frame-specific observers. Examples: Log all frames from all services:: observers = DebugLogObserver() Log specific frame types from any source/destination:: from pipecat.frames.frames import LLMTextFrame, TranscriptionFrame observers=[ DebugLogObserver(frame_types=(LLMTextFrame,TranscriptionFrame,)), ] Log frames with specific source/destination filters:: from pipecat.frames.frames import InterruptionFrame, UserStartedSpeakingFrame, LLMTextFrame from pipecat.observers.loggers.debug_log_observer import DebugLogObserver, FrameEndpoint from pipecat.transports.base_output import BaseOutputTransport from pipecat.services.stt_service import STTService observers=[ DebugLogObserver( frame_types={ # Only log InterruptionFrame when source is BaseOutputTransport InterruptionFrame: (BaseOutputTransport, FrameEndpoint.SOURCE), # Only log UserStartedSpeakingFrame when destination is STTService UserStartedSpeakingFrame: (STTService, FrameEndpoint.DESTINATION), # Log LLMTextFrame regardless of source or destination type LLMTextFrame: None, } ), ] N frame_types.exclude_fieldsc sbtjdi|i|_|dur!t|trdd|D|_n||_|dur*||_dShd|_dS)aInitialize the debug log observer. Args: frame_types: Frame types to log. Can be: - Tuple of frame types to log all instances - Dict mapping frame types to filter configurations - None to log all frames Filter configurations can be None (log all instances) or a tuple of (service_type, endpoint) to filter on specific services. exclude_fields: Field names to exclude from logging. Defaults to excluding binary data fields like 'audio', 'image', 'images'. **kwargs: Additional arguments passed to parent class. NcSsi|]}|dqS)Nr).0 frame_typerrr ksz-DebugLogObserver.__init__..>audioimageimagesr)super__init__ frame_filters isinstancetupler)selfrrkwargs __class__rrr$Ls zDebugLogObserver.__init__cCs|durdSt|tr|St|ttfr5t|dkrdSt|dtr1t|dkr1t|dSt|St|ttfrCt|dSt|drZt t |drZ|j j d | St|S) zFormat a value for logging.NNonerz[]z itemsz bytesget_messages_for_loggingz with messages: )r&strlistr'lendictbytes bytearrayhasattrcallablegetattrr+rr.)r(valuerrr _format_value{s"   zDebugLogObserver._format_valuecCsr|jsdS|jD],\}}t||r6|durdS|\}}|tjkr*t||S|tjkr6t||Sq dS)z7Determine if a frame should be logged based on filters.TNF)r%itemsr&rrr)r(framesrcdstr filter_config service_typeendpointrrr_should_log_frames   z"DebugLogObserver._should_log_framedatac s|j}|j}|j}|j}|j}||||sdS|tjkr dnd}|d}|jj } g} t |rYt |D]$} | j |j vr=q4t|| j } | durHq4|| } | | j d| q4| rmd| }| d|d|d d }n | d|d d }t|d|d|d|dS) zProcess a frame being pushed into the pipeline. Logs frame details to the console with all relevant fields and values. Args: data: Event data containing the frame, source, destination, direction, and timestamp. Nu→u←iʚ;z: z,  z at z.2fs)source destinationr; direction timestamprAr DOWNSTREAMr+rrrnamerr7r9appendjoinr debug)r(rBr<r=r;rGrHarrowtime_sec class_name frame_detailsfieldr8formatted_valuedetailsmessagerrr on_push_frames4     $zDebugLogObserver.on_push_frame)NN)rrrrrr r r r rrrr/r$r9rArrV __classcell__rrr*rr%s*. /rN)r dataclassesrrenumrrtypingrrrr r r logurur pipecat.frames.framesr pipecat.observers.base_observerrr"pipecat.processors.frame_processorrrrrrrrs