Update examples to use default allow_interruptions, fixes to align examples

This commit is contained in:
Mark Backman
2025-06-19 10:02:16 -04:00
parent b5c0ac5f25
commit 9146def21b
147 changed files with 195 additions and 212 deletions

View File

@@ -326,7 +326,10 @@ async def run_bot(
# Create pipeline task
voicemail_detection_pipeline_task = PipelineTask(
voicemail_detection_pipeline,
params=PipelineParams(allow_interruptions=True),
params=PipelineParams(
enable_metrics=True,
enable_usage_metrics=True,
),
)
# ------------ RETRY LOGIC VARIABLES ------------
@@ -471,7 +474,10 @@ async def run_bot(
# Create pipeline task
human_conversation_pipeline_task = PipelineTask(
human_conversation_pipeline,
params=PipelineParams(allow_interruptions=True),
params=PipelineParams(
enable_metrics=True,
enable_usage_metrics=True,
),
)
# Update participant left handler for human conversation phase

View File

@@ -454,7 +454,10 @@ async def run_bot(
# Create pipeline task
task = PipelineTask(
pipeline,
params=PipelineParams(allow_interruptions=True),
params=PipelineParams(
enable_metrics=True,
enable_usage_metrics=True,
),
)
# ------------ EVENT HANDLERS ------------

View File

@@ -148,7 +148,8 @@ async def run_bot(
task = PipelineTask(
pipeline,
params=PipelineParams(
allow_interruptions=True # Enable barge-in so callers can interrupt the bot
enable_metrics=True,
enable_usage_metrics=True,
),
)
logger.debug("setup task")

View File

@@ -140,7 +140,13 @@ async def run_bot(
)
# Create pipeline task
task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
task = PipelineTask(
pipeline,
params=PipelineParams(
enable_metrics=True,
enable_usage_metrics=True,
),
)
# ------------ RETRY LOGIC VARIABLES ------------
max_retries = 5

View File

@@ -107,7 +107,6 @@ async def run_bot(
params: FunctionCallParams,
):
"""Function the bot can call to terminate the call."""
await params.llm.queue_frame(EndTaskFrame(), FrameDirection.UPSTREAM)
tools = [
@@ -211,7 +210,13 @@ async def run_bot(
)
# Create pipeline task
task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
task = PipelineTask(
pipeline,
params=PipelineParams(
enable_metrics=True,
enable_usage_metrics=True,
),
)
# ------------ RETRY LOGIC VARIABLES ------------
max_retries = 5

View File

@@ -95,7 +95,8 @@ async def run_bot(room_url: str, token: str, call_id: str, sip_uri: str) -> None
task = PipelineTask(
pipeline,
params=PipelineParams(
allow_interruptions=True # Enable barge-in so callers can interrupt the bot
enable_metrics=True,
enable_usage_metrics=True,
),
)

View File

@@ -134,7 +134,13 @@ async def run_bot(
)
# Create pipeline task
task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
task = PipelineTask(
pipeline,
params=PipelineParams(
enable_metrics=True,
enable_usage_metrics=True,
),
)
# ------------ RETRY LOGIC VARIABLES ------------
max_retries = 5