2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-05-01 04:47:45 +00:00

Include ommitted file from previous commit

This commit is contained in:
Jarrod Johnson
2026-04-29 11:57:09 -04:00
parent d2f23b475f
commit ee8a8bdac7

View File

@@ -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]