Selam,
"""End call function tool."""
from liveki...
# ask-aia
astonishing-waitress-60915
03/05/2026, 3:02 PMSelam,
"""End call function tool."""
from livekit.agents import RunContext, get_job_context
from livekit.agents.llm import function_tool
from ..utils.logger import get_logger
from ..utils.sip import hangup
from ..utils.speech_output import speak_message
logger = get_logger("end_call")
@function_tool(
name="end_call",
description=(
"Telefon görüşmesini kapatır. "
"Yalnızca kullanıcı açıkça kapatmak istediğinde çağır. "
"Bu aracı çağırmadan önce veda cümlesi kurma. "
"Söylenecek tek cümleyi sadece 'closing_message' parametresine yaz. "
"Araç, aktif konuşmayı keser ve bu cümleyi sesli oynatır; "
"kullanıcı bu sırada araya girerse kapatmayı iptal eder."
),
)
async def end_call(
context: RunContext,
closing_message: str = "Görüşme için teşekkür ederim, iyi günler.",
) -> str | None:
"""Telefon görüşmesini kapat.
Akış:
1) Mevcut agent konuşması varsa keser.
2)
closing_messaget
tall-airline-16756
03/05/2026, 3:02 PMThanks for reaching out, İbrahim. I'm an AI assistant and I'm here to help. Give me a moment while I research this topic.
tall-airline-16756
03/05/2026, 3:03 PMSelam — teşekkürler, paylaştığın kod ve loglar çok yardımcı oldu. Sorunun ne olduğuna ve nasıl düzeltebileceğine dair kısa ve uygulanabilir bir yanıt hazırladım.
Özet olarak ne oluyor
• Hata "speech not done in time after interruption, cancelling the speech arbitrarily." — bu, konuşma (TTS/playout) bir kesintiden sonra 5 saniye içinde tamamlanmadığı için framework tarafından iptal edildiğini gösteriyor.
• Loglarda ayrıca Google Realtime model kullanıldığı görünüyor (gemini-2.5-flash-native-audio-preview…). Realtime modellerde playout ve kesinti işleyişi sunucu tarafı davranışları nedeniyle beklenmedik gecikmeler veya eksik tamamlanma sinyalleri verebilir.
• Mevcut kodunda
speak_message(..., wait_for_playout=True, allow_interruptions=True)handle.interrupted.interrupted.done Copy code
handle = speak_message(
session,
closing_message.strip() or "Görüşme için teşekkür ederim, iyi günler.",
wait_for_playout=False,
allow_interruptions=True,
)
# kısa bir grace period
await asyncio.sleep(0.5)
if getattr(handle, "interrupted", False):
<http://logger.info|logger.info>("Kullanıcı araya girdi, kapatma iptal ediliyor")
return None
# devam edip kapat
await hangup(ctx, reason="agent_ended")wait_for_playout=Falsespeech_idwait_for_playout=Truespeak_messageSpeechHandlea
astonishing-waitress-60915
03/05/2026, 3:04 PMdef _is_realtime_session(session: AgentSession) -> bool:
"""Return True when session runs in realtime pipeline mode."""
agent = getattr(session, "_agent", None)
return bool(agent and getattr(agent, "_pipeline_mode", "standard") == "realtime")
async def speak_message(
session: AgentSession,
message: str,
*,
allow_interruptions: bool = True,
add_to_chat_ctx: bool = False,
wait_for_playout: bool = False,
) -> bool:
"""
Speak
messaget
tall-airline-16756
03/05/2026, 3:05 PMTeşekkürler — ek kodla beraber durumu net gördüm. Paylaştığın
speak_message_is_realtime_sessionilewait_for_playout=Truehandle.interruptedwait_for_playout=Falsehandleinterrupted Copy code
handle = speak_message(
session,
closing_message.strip() or "Görüşme için teşekkür ederim, iyi günler.",
wait_for_playout=False,
allow_interruptions=True,
) Copy code
await asyncio.sleep(0.5) # 0.5s gibi kısa bir bekleme
if getattr(handle, "interrupted", False):
<http://logger.info|logger.info>("Kullanıcı araya girdi, kapatma iptal ediliyor - room: {ctx.room.name}")
return None Copy code
# closing message çalınıyor; kullanıcı kesmediyse kapat
await hangup(ctx, reason="agent_ended")handle.wait_for_playout()asyncio.wait_for(handle, timeout=...)await asyncio.wait_for(handle.wait_for_playout(), timeout=10.0)speak_messagehandleinterrupted.interruptedhandle2 Views