Skip to content

Commit 69930c5

Browse files
committed
fix: add exception handling to AsyncStream client close
1 parent ed836de commit 69930c5

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

plugins/getstream/vision_agents/plugins/getstream/stream_edge_transport.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -503,8 +503,11 @@ async def close(self):
503503
except Exception:
504504
logger.exception("Error during connection leave in StreamEdge.close()")
505505
self._real_connection = None
506-
if self.client:
507-
await self.client.aclose()
506+
try:
507+
if self.client:
508+
await self.client.aclose()
509+
except Exception:
510+
logger.exception("Error closing AsyncStream client")
508511
self._call = None
509512

510513
async def send_custom_event(self, data: dict) -> None:

0 commit comments

Comments
 (0)