examples: assistant aggregator should always goes after transport
This commit is contained in:
@@ -74,8 +74,8 @@ async def main():
|
|||||||
tma_in, # User responses
|
tma_in, # User responses
|
||||||
llm, # LLM
|
llm, # LLM
|
||||||
tts, # TTS
|
tts, # TTS
|
||||||
tma_out, # Goes before the transport because cartesia has word-level timestamps!
|
|
||||||
transport.output(), # Transport bot output
|
transport.output(), # Transport bot output
|
||||||
|
tma_out # Assistant spoken responses
|
||||||
])
|
])
|
||||||
|
|
||||||
task = PipelineTask(pipeline, PipelineParams(allow_interruptions=True, enable_metrics=True))
|
task = PipelineTask(pipeline, PipelineParams(allow_interruptions=True, enable_metrics=True))
|
||||||
|
|||||||
@@ -147,8 +147,8 @@ Your task is to help the user understand and learn from this article in 2 senten
|
|||||||
tma_in,
|
tma_in,
|
||||||
llm,
|
llm,
|
||||||
tts,
|
tts,
|
||||||
tma_out,
|
|
||||||
transport.output(),
|
transport.output(),
|
||||||
|
tma_out,
|
||||||
])
|
])
|
||||||
|
|
||||||
task = PipelineTask(pipeline, PipelineParams(allow_interruptions=True, enable_metrics=True))
|
task = PipelineTask(pipeline, PipelineParams(allow_interruptions=True, enable_metrics=True))
|
||||||
|
|||||||
Reference in New Issue
Block a user