await

deluxghost · Feb 19, 2018 · ca94514 · ca94514
1 parent 37ac5ba
commit ca94514
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ASF_IPC/__init__.py b/ASF_IPC/__init__.py
@@ -124,7 +124,7 @@ async def get_log(self):
         ws_url = self._build_endpoint('Log', ws=True)
         headers = self._add_auth()
         try:
-            websocket = websockets.connect(ws_url, extra_headers=headers)
+            websocket = await websockets.connect(ws_url, extra_headers=headers)
         except ConnectionRefusedError:
             raise error.ASF_ConnectionError(ws_url)
         while True: