From c4588ec85a4977c7545157ad6429729f27db6433 Mon Sep 17 00:00:00 2001
From: Loonride <22580625+Loonride@users.noreply.github.com>
Date: Thu, 24 Jun 2021 01:19:51 -0500
Subject: [PATCH] switch to correct websockets connect call

---
 funcx_sdk/funcx/sdk/asynchronous/ws_polling_task.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/funcx_sdk/funcx/sdk/asynchronous/ws_polling_task.py b/funcx_sdk/funcx/sdk/asynchronous/ws_polling_task.py
index 825f52b7a..e9932a543 100644
--- 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,