wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rm TranscriptProcessor 2

Browse Source
This commit is contained in:
ivaaan
2025-11-18 20:41:10 +01:00
parent 4c3fd42b1c
commit f325eeb95b
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
examples/foundational/07ae-interruptible-hume.py
View File

@@ -91,12 +91,10 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
transport.input(), # Transport user input transport.input(), # Transport user input
rtvi, rtvi,
stt, stt,
transcript.user(), # User transcripts
context_aggregator.user(), # User responses context_aggregator.user(), # User responses
llm, # LLM llm, # LLM
tts, # TTS (HumeTTSService with word timestamps) tts, # TTS (HumeTTSService with word timestamps)
transport.output(), # Transport bot output transport.output(), # Transport bot output
transcript.assistant(), # Assistant transcripts with timestamps
context_aggregator.assistant(), # Assistant spoken responses context_aggregator.assistant(), # Assistant spoken responses
] ]
) )
@@ -123,13 +121,6 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
async def on_client_ready(rtvi): async def on_client_ready(rtvi):
await rtvi.set_bot_ready() await rtvi.set_bot_ready()
@transcript.event_handler("on_transcript_update")
async def on_transcript_update(processor, frame):
"""Log transcript updates to show timestamps in conversation."""
for msg in frame.messages:
timestamp_str = f"[{msg.timestamp}] " if msg.timestamp else ""
logger.info(f"📝 Transcript: {timestamp_str}{msg.role}: {msg.content}")
@transport.event_handler("on_client_connected") @transport.event_handler("on_client_connected")
async def on_client_connected(transport, client): async def on_client_connected(transport, client):
logger.info(f"Client connected") logger.info(f"Client connected")