From d2f23b475f19e31d7aec8cdbf2795c9a239e2cf6 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 29 Apr 2026 11:47:55 -0400 Subject: [PATCH] Fix some failure to await --- confluent_server/confluent/httpapi.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/httpapi.py b/confluent_server/confluent/httpapi.py index e1e53533..c4bfe42b 100644 --- a/confluent_server/confluent/httpapi.py +++ b/confluent_server/confluent/httpapi.py @@ -570,9 +570,9 @@ async def wsock_handler(req): print(repr(clientmsg)) finally: for cons in myconsoles: - myconsoles[cons].destroy() + await myconsoles[cons].destroy() if asess: - asess.destroy() + await asess.destroy() return rsp if '/console/session' in ws.path or '/shell/sessions/' in ws.path: def datacallback(data):