Pipeline Idle Detection

from pipecat.pipeline.worker import PipelineParams, PipelineWorker

# Default configuration - cancel after 5 minutes of inactivity
worker = PipelineWorker(pipeline)

# Custom configuration
worker = PipelineWorker(
    pipeline,
    idle_timeout_secs=600,  # 10 minute timeout
    idle_timeout_frames=(BotSpeakingFrame,),  # Only monitor bot speaking
    cancel_on_idle_timeout=False,  # Don't auto-cancel, just notify
)

@worker.event_handler("on_idle_timeout")
async def on_idle_timeout(worker):
    logger.info("Pipeline has been idle for too long")
    # Perform any custom cleanup or logging
    # Note: If cancel_on_idle_timeout=True, the pipeline will be cancelled after this handler runs

from pipecat.frames.frames import EndFrame, TTSSpeakFrame
from pipecat.pipeline.pipeline import Pipeline
from pipecat.workers.runner import WorkerRunner
from pipecat.pipeline.worker import PipelineWorker

# Create pipeline
pipeline = Pipeline([...])

# Configure worker with custom idle settings
worker = PipelineWorker(
    pipeline,
    idle_timeout_secs=180,  # 3 minutes
    cancel_on_idle_timeout=False  # Don't auto-cancel
)

# Add event handler for idle timeout
@worker.event_handler("on_idle_timeout")
async def on_idle_timeout(worker):
    logger.info("Conversation has been idle for 3 minutes")

    # Add a farewell message
    await worker.queue_frame(TTSSpeakFrame("I haven't heard from you in a while. Goodbye!"))

    # Then end the conversation gracefully
    await worker.queue_frame(EndFrame())

runner = WorkerRunner()

await runner.run(worker)