@function_tool() async def transfer_call(self, ctx: RunContext): transfer_to = "+918956521667" if not transfer_to: return "Cannot transfer call: no transfer target specified." logger.info(f"Transferring call to {transfer_to}") await ctx.session.generate_reply( instructions="Let the user know you'll be transferring them in the current language." ) job_ctx = get_job_context() try: await job_ctx.api.sip.transfer_sip_participant( api.TransferSIPParticipantRequest( room_name=job_ctx.room.name, participant_identity=self.participant.identity, transfer_to=f"tel:{transfer_to}", ) ) logger.info(f"Transferred call to {transfer_to}") except Exception as e: logger.error(f"Error transferring call: {e}") await ctx.session.generate_reply( instructions="There was an error transferring the call in the current language." ) await self.hangup() this code show Feb 25 080135 ip-172-31-23-35.ec2.internal python3[1962643]: {"message": "Transferring call to +918956521667", "level": "INFO", "name": "outbound-caller", "pid": 1962661, "job_id": "AJ_HE57VTzGLfzn", "room_id": "RM_KTH2HQgTGzvN", "timestamp": "2026-02-25T080135.634919+00:00"} Feb 25 080140 ip-172-31-23-35.ec2.internal python3[1962643]: {"message": "Error in _realtime_reply_task\nTraceback (most recent call last):\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/utils/log.py\", line 16, in async_fn_logs\n return await fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/voice/agent_activity.py\", line 2189, in _realtime_reply_task\n generation_ev = await self._rt_session.generate_reply(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\nlivekit.agents.llm.realtime.RealtimeError: generate_reply timed out waiting for generation_created event.", "level": "ERROR", "name": "livekit.agents", "exc_info": "Traceback (most recent call last):\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/utils/log.py\", line 16, in async_fn_logs\n return await fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/voice/agent_activity.py\", line 2189, in _realtime_reply_task\n generation_ev = await self._rt_session.generate_reply(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\nlivekit.agents.llm.realtime.RealtimeError: generate_reply timed out waiting for generation_created event.", "pid": 1962661, "job_id": "AJ_HE57VTzGLfzn", "room_id": "RM_KTH2HQgTGzvN", "timestamp": "2026-02-25T080140.639295+00:00"} Feb 25 080140 ip-172-31-23-35.ec2.internal python3[1962643]: {"message": "Error transferring call: TwirpError(code=permission_denied, message=twirp error unknown: sip status: 403: Forbidden, status=403, metadata={'error_details': 'CAcSGnNpcCBzdGF0dXM6IDQwMzogRm9yYmlkZGVuGjcKJXR5cGUuZ29vZ2xlYXBpcy5jb20vbGl2ZWtpdC5TSVBTdGF0dXMSDgiTAxIJRm9yYmlkZGVu', 'sip_status': 'Forbidden', 'sip_status_code': '403'})", "level": "ERROR", "name": "outbound-caller", "pid": 1962661, "job_id": "AJ_HE57VTzGLfzn", "room_id": "RM_KTH2HQgTGzvN", "timestamp": "2026-02-25T080140.669629+00:00"} Feb 25 080145 ip-172-31-23-35.ec2.internal python3[1962643]: {"message": "Error in _realtime_reply_task\nTraceback (most recent call last):\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/utils/log.py\", line 16, in async_fn_logs\n return await fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/voice/agent_activity.py\", line 2189, in _realtime_reply_task\n generation_ev = await self._rt_session.generate_reply(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\nlivekit.agents.llm.realtime.RealtimeError: generate_reply timed out waiting for generation_created event.", "level": "ERROR", "name": "livekit.agents", "exc_info": "Traceback (most recent call last):\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/utils/log.py\", line 16, in async_fn_logs\n return await fn(*args, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^\n File \"/home/ec2-user/livekit-agent/venv/lib64/python3.11/site-packages/livekit/agents/voice/agent_activity.py\", line 2189, in _realtime_reply_task\n generation_ev = await self._rt_session.generate_reply(\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\nlivekit.agents.llm.realtime.RealtimeError: generate_reply timed out waiting for generation_created event.", "pid": 1962661, "job_id": "AJ_HE57VTzGLfzn", "room_id": "RM_KTH2HQgTGzvN", "timestamp": "2026-02-25T080145.672502+00:00"}

Thanks for reaching out, Sujata. I'm an AI assistant and I'm here to help. Give me a moment while I research this topic.

give me correct function that not show timout error

Thanks — I see you want a corrected function that avoids the

generate_reply

timeout error. I’ll give you a safe, practical version that: • Ensures the transfer proceeds even if reply generation times out or fails. • Uses explicit timeout handling for

generate_reply

. • Logs and reports errors clearly so you can debug later. • Sends a clean E.164

transfer_to

value to the SIP API. Before you paste this in: confirm the correct participant identity you should use (in your earlier snippet you used

self.participant.identity

— the example below uses

self.participant.identity

but I can adjust if your code stores it elsewhere). Example function (with timeout handling and robust error flow):

import asyncio
from asyncio import TimeoutError

@function_tool()
async def transfer_call(self, ctx: RunContext):
    """
    Inform the user (best-effort) then transfer the SIP participant.
    This separates generate_reply from the transfer so timeouts in reply generation
    won't block the transfer, and it uses an explicit timeout for generate_reply.
    """
    # Use a plain E.164 string for transfer target
    transfer_to = "tel:+918956521667"
    if not transfer_to:
        return "Cannot transfer call: no transfer target specified."

    # 1) Try to generate the reply but don't let it block indefinitely
    REPLY_TIMEOUT_SECONDS = 8  # adjust higher/lower depending on your model latency

    try:
        # run generate_reply with an explicit timeout
        await asyncio.wait_for(
            ctx.session.generate_reply(
                instructions="Let the user know you'll be transferring them in the current language."
            ),
            timeout=REPLY_TIMEOUT_SECONDS,
        )
        <http://logger.info|logger.info>("Spoken notification generated before transfer.")
    except TimeoutError:
        logger.warning("generate_reply timed out; continuing with transfer.")
    except Exception as e:
        logger.error(f"Non-critical error generating reply: {e}; continuing with transfer.")

    # 2) Proceed with the transfer (critical path)
    job_ctx = get_job_context()
    try:
        await job_ctx.api.sip.transfer_sip_participant(
            api.TransferSIPParticipantRequest(
                room_name=job_ctx.room.name,
                participant_identity=self.participant.identity,
                transfer_to=transfer_to,
            )
        )
        <http://logger.info|logger.info>(f"Transferred call to {transfer_to}")
        return "Call transferred"
    except Exception as e:
        logger.error(f"Error transferring call: {e}")
        # return or take additional actions (hangup, retry, etc.)
        try:
            # attempt to inform user of failure (best-effort, with timeout)
            await asyncio.wait_for(
                ctx.session.generate_reply(instructions="There was an error transferring the call in the current language."),
                timeout=REPLY_TIMEOUT_SECONDS,
            )
        except Exception:
            logger.warning("Could not generate failure announcement.")
        # perform cleanup if required
        await self.hangup()
        return "Could not transfer call"

Notes and recommended adjustments • Timeout value: Increase REPLY_TIMEOUT_SECONDS if your model normally needs more time. If your LLM is unreliable, keep the timeout so transfers are not blocked. • Pre-generate audio: If you repeatedly use identical transfer phrasing, consider pre-generating the audio (TTS) and playing that instead of calling

generate_reply

live — this removes LLM variability. • Logging: Keep detailed logs around the transfer call and the exact

transfer_to

value. Your earlier logs showed markdown-like brackets — ensure the value you pass is plain

tel:+918956521667

. • SIP 403: If transfers still fail with SIP 403, the cause is likely permissions/config on the SIP trunk. The function above prevents the LLM timeout from blocking transfers but won’t change carrier permissions. • Retries: If you want automatic retries for transient SIP errors, I can add a retry/backoff wrapper to the transfer call. If you want, I can: • Add exponential retries around

transfer_sip_participant

(with limits). • Show an alternate flow that always returns the spoken reply to the user before transferring (i.e., wait but with longer timeout). • Help interpret SIP logs if you still see 403 Forbidden errors. Which of those would you like next? Sources: Amazon Nova Sonic integration guide | LiveKit Documentation | Agent speech and audio | LiveKit Documentation