o id @s|dZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z ddlmZddlmZddlmZGdd d e Zd S) z!LLM logging observer for Pipecat.)logger)FunctionCallInProgressFrameFunctionCallResultFrameLLMContextFrameLLMFullResponseEndFrameLLMFullResponseStartFrameLLMMessagesFrame LLMTextFrame) BaseObserver FramePushed)OpenAILLMContextFrame)FrameDirection) LLMServicec@seZdZdZdefddZdS)LLMLogObserveraObserver to log LLM activity to the console. Logs all frame instances (only from/to LLM service) of: - LLMFullResponseStartFrame - LLMFullResponseEndFrame - LLMTextFrame - FunctionCallInProgressFrame - LLMMessagesFrame - OpenAILLMContextFrame This allows you to track when the LLM starts responding, what it generates, and when it finishes. datac s|j}|j}|j}|j}|j}t|tst|tsdS|d}d}t|ttfrGt|tr0dnd} t d|d|d| d |d d dSt|t rbt d|d|d |j d |d d dSt|t r|tjkrt d|d|d|jd|jd|jd|d d dSt|trt d|d|d|jd |d d dSt|ttfrt|tr|jjn|j} t d|d|d| d |d d dSt|trt d|d|d|jd|jd |d d dSdS)zHandle frame push events and log LLM-related activities. Args: data: The frame push event data containing source, destination, frame, direction, and timestamp information. Niʚ;u→STARTENDu🧠  z LLM z RESPONSE at z.2fsz LLM GENERATING: z at z LLM FUNCTION CALL (z): (z) at z LLM MESSAGES FRAME: z LLM CONTEXT FRAME: z LLM FUNCTION CALL RESULT ()source destinationframe direction timestamp isinstancerrrrdebugr textrr DOWNSTREAM tool_call_id function_name argumentsrmessagesrr context get_messagesrresult) selfrsrcdstrrrtime_secarroweventr"r,^/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/observers/loggers/llm_log_observer.py on_push_frame*sH* , 0   * (zLLMLogObserver.on_push_frameN)__name__ __module__ __qualname____doc__r r.r,r,r,r-rsrN)r2logururpipecat.frames.framesrrrrrrr pipecat.observers.base_observerr r 1pipecat.processors.aggregators.openai_llm_contextr "pipecat.processors.frame_processorr pipecat.services.llm_servicerrr,r,r,r-s $