From ee8a8bdac7dcb3d89bdebd20aa063240152af617 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 29 Apr 2026 11:57:09 -0400 Subject: [PATCH] Include ommitted file from previous commit --- confluent_server/confluent/asynchttp.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/asynchttp.py b/confluent_server/confluent/asynchttp.py index 18239b1a..d768bce3 100644 --- a/confluent_server/confluent/asynchttp.py +++ b/confluent_server/confluent/asynchttp.py @@ -84,9 +84,9 @@ class AsyncSession(object): def add_console_session(self, sessionid): self.consoles.add(sessionid) - def destroy(self): + async def destroy(self): for console in self.consoles: - _consolesessions[console]['session'].destroy() + await _consolesessions[console]['session'].destroy() self.consoles = set([]) del _asyncsessions[self.asyncid]