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

Fix some failure to await

This commit is contained in:
Jarrod Johnson
2026-04-29 11:47:55 -04:00
parent ae5afc526a
commit d2f23b475f

View File

@@ -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):