wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix StopAsyncIteration in parse_telephony_websocket

Browse Source 
Handle WebSocket disconnections gracefully when telephony providers send
fewer messages than expected. Adds explicit StopAsyncIteration handling
for both first and second message retrieval.

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
This commit is contained in:
James Hush
2026-02-03 16:25:07 +08:00
parent 4c10ddb7bb
commit a627597bca
1 changed files with 18 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/pipecat/runner/utils.py
View File

@@ -147,19 +147,28 @@ async def parse_telephony_websocket(websocket: WebSocket):
try:
# First message
first_message_raw = await start_data.__anext__()
logger.trace(f"First message: {first_message_raw}")
try:
first_message = json.loads(first_message_raw)
except json.JSONDecodeError:
first_message = {}
first_message_raw = await start_data.__anext__()
logger.trace(f"First message: {first_message_raw}")
try:
first_message = json.loads(first_message_raw)
except json.JSONDecodeError:
first_message = {}
except StopAsyncIteration:
logger.error("WebSocket closed without sending any messages")
raise ValueError("WebSocket closed before receiving telephony handshake messages")
# Second message
second_message_raw = await start_data.__anext__()
logger.trace(f"Second message: {second_message_raw}")
try:
second_message = json.loads(second_message_raw)
except json.JSONDecodeError:
second_message_raw = await start_data.__anext__()
logger.trace(f"Second message: {second_message_raw}")
try:
second_message = json.loads(second_message_raw)
except json.JSONDecodeError:
second_message = {}
except StopAsyncIteration:
# Only one message received - use it for detection
logger.warning("Only received one WebSocket message, expected two")
second_message = {}
# Try auto-detection on both messages