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