fix(server.py): check attr sse_generator returned object

This commit is contained in:
r-bit-rry 2025-11-26 10:55:28 +02:00
parent 91f1b352b4
commit 57f8f6d3af

View file

@ -205,7 +205,11 @@ async def sse_generator(event_gen_coroutine):
except asyncio.CancelledError:
logger.info("Generator cancelled")
if event_gen:
# Some generators (like OpenAI's AsyncStream) only have close()
if hasattr(event_gen, "aclose"):
await event_gen.aclose()
elif hasattr(event_gen, "close"):
await event_gen.close()
except Exception as e:
logger.exception("Error in sse_generator")
yield create_sse_event(