@@ -88,14 +88,12 @@ def _prepare_credentials(self, **config):
88
88
# The connector should not be owned by aiohttp.ClientSession since
89
89
# it is closed by fsspec (HTTPFileSystem.close_session)
90
90
client_kwargs ["connector_owner" ] = False
91
+
91
92
client_kwargs ["connect_timeout" ] = config .get (
92
93
"connect_timeout" , self .REQUEST_TIMEOUT
93
94
)
94
- client_kwargs ["sock_connect_timeout" ] = config .get (
95
- "sock_connect_timeout" , self .REQUEST_TIMEOUT
96
- )
97
- client_kwargs ["sock_read_timeout" ] = config .get (
98
- "sock_read_timeout" , self .REQUEST_TIMEOUT
95
+ client_kwargs ["read_timeout" ] = config .get (
96
+ "read_timeout" , self .REQUEST_TIMEOUT
99
97
)
100
98
101
99
# Allow reading proxy configurations from the environment.
@@ -108,8 +106,7 @@ def _prepare_credentials(self, **config):
108
106
async def get_client (
109
107
self ,
110
108
connect_timeout : Optional [float ],
111
- sock_connect_timeout : Optional [float ],
112
- sock_read_timeout : Optional [float ],
109
+ read_timeout : Optional [float ],
113
110
** kwargs ,
114
111
):
115
112
import aiohttp
@@ -132,8 +129,8 @@ async def get_client(
132
129
kwargs ["timeout" ] = aiohttp .ClientTimeout (
133
130
total = None ,
134
131
connect = connect_timeout ,
135
- sock_connect = sock_connect_timeout ,
136
- sock_read = sock_read_timeout ,
132
+ sock_connect = connect_timeout ,
133
+ sock_read = read_timeout ,
137
134
)
138
135
139
136
return ReadOnlyRetryClient (** kwargs )
0 commit comments