diff --git a/deepgram/clients/live/v1/async_client.py b/deepgram/clients/live/v1/async_client.py index e948a2f7..a63b18c2 100644 --- a/deepgram/clients/live/v1/async_client.py +++ b/deepgram/clients/live/v1/async_client.py @@ -225,7 +225,7 @@ async def _start(self) -> None: self.logger.error( f"WebSocket connection closed with code {e.code}: {e.reason}" ) - self._emit(LiveTranscriptionEvents.Error, error=error) + await self._emit(LiveTranscriptionEvents.Error, error=error) self.logger.debug("AsyncLiveClient._start LEAVE") raise except Exception as e: @@ -235,7 +235,7 @@ async def _start(self) -> None: "message": f"{e}", "variant": "", } - self._emit(LiveTranscriptionEvents.Error, error) + await self._emit(LiveTranscriptionEvents.Error, error) self.logger.error("Exception in _start: %s", error=error) self.logger.debug("AsyncLiveClient._start LEAVE") raise