webhook_on_shutdown

import asyncio
from livekit_agents import AgentSession, JobContext, inference, silero
import logging

logger = logging.getLogger(__name__)

async def entrypoint(ctx: JobContext):
    # Create session with components
    session = AgentSession(
        stt=inference.STT(),
        llm=inference.LLM(),
        tts=inference.TTS(),
        vad=silero.VAD.load(),
    )

    # Register shutdown callback on the job context
    async def webhook_on_shutdown():
        <http://logger.info|logger.info>("Running post-shutdown webhook...")
        # perform webhook call to your backend, send logs, etc.
        # Example (pseudo):
        # await <http://http_client.post|http_client.post>(WEBHOOK_URL, json={"room": ctx.room, "reason": "shutdown"})
        <http://logger.info|logger.info>("Post-shutdown webhook complete.")

        # Optionally: delete the room from your server here (if permitted)
        # await delete_room_api(ctx.room)

    ctx.add_shutdown_callback(webhook_on_shutdown)

    # Start the session (agent implementation omitted)
    await session.start(agent=MyAgent(), room=ctx.room)

    # ... normal agent work ...

    # When you need to shut down gracefully:
    # This requests a graceful shutdown and allows the session to drain (finish pending speech)
    await session.shutdown(drain=True)

    # Wait for session to fully close if shutdown returns quickly
    await session.wait_closed()

    # If you prefer to delete room from here rather than inside webhook:
    # await delete_room_api(ctx.room)

import { defineAgent, JobContext } from "livekit-agents";
import { inference } from "livekit-agents/inference";
import { silero } from "livekit-agents/vad";

export default defineAgent({
  entry: async (ctx: JobContext) => {
    const session = new voice.AgentSession({
      stt: new inference.STT(),
      llm: new inference.LLM(),
      tts: new inference.TTS(),
      vad: await silero.VAD.load(),
    });

    // Register shutdown callback
    ctx.addShutdownCallback(async () => {
      console.log("Running post-shutdown webhook...");
      // perform webhook call to your backend, send logs, etc.
      // await fetch(WEBHOOK_URL, { method: "POST", body: JSON.stringify({ room: ctx.room }) });
      console.log("Post-shutdown webhook complete.");

      // Optionally: delete the room from your server here
      // await deleteRoomApi(ctx.room);
    });

    await session.start({ agent: new MyAgent(), room: ctx.room });

    // ... normal agent work ...

    // Initiate graceful shutdown via the session API or job context
    // Using job context:
    await ctx.shutdown({ drain: true });

    // Or using the session API if provided:
    // await session.shutdown({ drain: true });

    // Wait until fully closed if an awaitable exists
    await session.waitClosed?.();
  },
});

drain=True

drain: true

egress_ended

room_finished

webhook_on_shutdown

await session.wait_closed()