Merge pull request globus#533 from funcx-faas/ws_connect_change_2

switch to correct websockets connect call
slateci · Jun 24, 2021 · 6f3c1cf · 6f3c1cf
2 parents 7a1b85c + c4588ec
commit 6f3c1cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/funcx_sdk/funcx/sdk/asynchronous/ws_polling_task.py b/funcx_sdk/funcx/sdk/asynchronous/ws_polling_task.py
@@ -79,7 +79,7 @@ def __init__(
     async def init_ws(self, start_message_handlers=True):
         headers = [self.get_auth_header()]
         try:
-            self.ws = await websockets.client.connect(
+            self.ws = await websockets.connect(
                 self.results_ws_uri, extra_headers=headers
             )
         # initial Globus authentication happens during the HTTP portion of the handshake,