File tree 1 file changed +4
-5
lines changed 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -40,7 +40,6 @@ class HTTPFileSystem(FileSystem):
40
40
41
41
def _prepare_credentials (self , ** config ):
42
42
import aiohttp
43
- from fsspec .asyn import fsspec_loop
44
43
45
44
credentials = {}
46
45
client_kwargs = credentials .setdefault ("client_kwargs" , {})
@@ -81,10 +80,10 @@ def _prepare_credentials(self, **config):
81
80
if "ssl_verify" in config :
82
81
connector_kwargs .update (ssl = make_context (config ["ssl_verify" ]))
83
82
84
- with fsspec_loop ():
85
- client_kwargs [ "connector" ] = aiohttp . TCPConnector (
86
- ** connector_kwargs
87
- )
83
+ client_kwargs [ "connector" ] = aiohttp . TCPConnector (
84
+ loop = self . fs . loop , ** connector_kwargs
85
+ )
86
+
88
87
# The connector should not be owned by aiohttp.ClientSession since
89
88
# it is closed by fsspec (HTTPFileSystem.close_session)
90
89
client_kwargs ["connector_owner" ] = False
You can’t perform that action at this time.
0 commit comments