qid dZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z ddlmZddlmZddlmZGdd e Zy ) z!LLM logging observer for Pipecat.)logger)FunctionCallInProgressFrameFunctionCallResultFrameLLMContextFrameLLMFullResponseEndFrameLLMFullResponseStartFrameLLMMessagesFrame LLMTextFrame) BaseObserver FramePushed)OpenAILLMContextFrame)FrameDirection) LLMServiceceZdZdZdefdZy)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. datacK|j}|j}|j}|j}|j}t |t st |t sy|dz }d}t |ttfr8t |trdnd} tjd|d|d| d |d d yt |tr.tjd|d|d |jd |d d yt |tr[|tjk7rHtjd|d|d|j d|j"d|j$d|d d yt |t&r.tjd|d|d|j(d |d d yt |t*t,frdt |t,r|j.j(n|j.j1} tjd|d|d| d |d d yt |t2r;tjd|d|d|j d|j4d |d d yyw)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 argumentsr messagesrr context get_messagesrresult) selfrsrcdstrrrtime_secarroweventr%s \/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/observers/loggers/llm_log_observer.py on_push_framezLLMLogObserver.on_push_frame*swkk NN NN #z*:c:3N }, e79PQ R)%1JKGQVE LL5QugU5'xPSnTUV W | , LL5Qug->uzznDQYZ]P^^_` a u9 :^666 LLuAeW$89K9K8LCPUPcPcOffghmhwhwgxx}GHK~LLMN / 0 LLwau$9%..9IhWZ^[\] 1FG He%:; &&]]//1  LL5q-A(4PXY\~]^_ ` 6 7 LLwau$?@R@R?SSVW\WcWcVddhiqruhvvwx 8sI I"N)__name__ __module__ __qualname____doc__r r0r/rrs 4 4r6rN)r4logururpipecat.frames.framesrrrrrr r pipecat.observers.base_observerr r 1pipecat.processors.aggregators.openai_llm_contextr "pipecat.processors.frame_processorrpipecat.services.llm_servicerrr5r6r/r=s9(FS=3D\Dr6