Skip to content

Commit ed3dd94

Browse files
committed
Sending error frame in case should not try to reconnect.
1 parent af5a0f2 commit ed3dd94

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/pipecat/services/websocket_service.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -137,6 +137,9 @@ async def _receive_task_handler(self, report_error: Callable[[ErrorFrame], Await
137137
success = await self._try_reconnect(report_error=report_error)
138138
if not success:
139139
break
140+
else:
141+
await report_error(ErrorFrame(message))
142+
break
140143

141144
@abstractmethod
142145
async def _connect(self):

0 commit comments

Comments
 (0)