fix aclose error

This commit is contained in:
Kai Wu 2025-06-16 15:04:31 -07:00
parent 40e2c97915
commit ff79643621

View file

@ -180,7 +180,7 @@ async def sse_generator(event_gen_coroutine):
except asyncio.CancelledError:
logger.info("Generator cancelled")
if event_gen:
await event_gen.aclose()
await event_gen.close()
except Exception as e:
logger.exception("Error in sse_generator")
yield create_sse_event(