Updated openai example to use on_tts_request and append_to_text.
This commit is contained in:
@@ -99,7 +99,7 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
|
|||||||
|
|
||||||
@llm.event_handler("on_function_calls_started")
|
@llm.event_handler("on_function_calls_started")
|
||||||
async def on_function_calls_started(service, function_calls):
|
async def on_function_calls_started(service, function_calls):
|
||||||
await tts.queue_frame(TTSSpeakFrame("Let me check on that."))
|
await tts.queue_frame(TTSSpeakFrame("Let me check on that.", append_to_context=False))
|
||||||
|
|
||||||
fetch_image_function = FunctionSchema(
|
fetch_image_function = FunctionSchema(
|
||||||
name="fetch_user_image",
|
name="fetch_user_image",
|
||||||
@@ -174,6 +174,10 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
|
|||||||
logger.info(f"Client disconnected")
|
logger.info(f"Client disconnected")
|
||||||
await task.cancel()
|
await task.cancel()
|
||||||
|
|
||||||
|
@tts.event_handler("on_tts_request")
|
||||||
|
async def on_tts_request(tts, context_id: str, text: str):
|
||||||
|
logger.debug(f"On TTS request: {context_id}: {text}")
|
||||||
|
|
||||||
runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
|
runner = PipelineRunner(handle_sigint=runner_args.handle_sigint)
|
||||||
|
|
||||||
await runner.run(task)
|
await runner.run(task)
|
||||||
|
|||||||
Reference in New Issue
Block a user