Skip to content

Commit 1bb92f4

Browse files
committed
Adjust to aiohttp deprecation about configuring shutdown_timeout
1 parent a9ed31c commit 1bb92f4

File tree

3 files changed

+5
-3
lines changed

3 files changed

+5
-3
lines changed

dask-gateway-server/dask_gateway_server/app.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -208,12 +208,13 @@ async def setup(self):
208208
handle_signals=False,
209209
access_log_class=AccessLogger,
210210
access_log=self.log,
211+
shutdown_timeout=15.0,
211212
)
212213
await self.runner.setup()
213214

214215
host, port = self.address.split(":")
215216
port = int(port)
216-
site = web.TCPSite(self.runner, host, port, shutdown_timeout=15.0, backlog=128)
217+
site = web.TCPSite(self.runner, host, port, backlog=128)
217218
await site.start()
218219
self.log.info("Dask-Gateway server started")
219220
self.log.info("- Private API server listening at http://%s", self.address)

dask-gateway-server/dask_gateway_server/backends/kubernetes/controller.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -438,12 +438,13 @@ async def setup(self):
438438
handle_signals=False,
439439
access_log_class=AccessLogger,
440440
access_log=self.log,
441+
shutdown_timeout=15.0,
441442
)
442443
await self.runner.setup()
443444

444445
host, port = self.address.split(":")
445446
port = int(port)
446-
site = web.TCPSite(self.runner, host, port, shutdown_timeout=15.0, backlog=128)
447+
site = web.TCPSite(self.runner, host, port, backlog=128)
447448
await site.start()
448449
self.log.info("%s started!", self.name)
449450
self.log.info("API listening at http://%s", self.address)

dask-gateway-server/requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
# These are dependencies for installing the dask-gateway-server package.
22
#
3-
aiohttp
3+
aiohttp>=3.9.0
44
async-timeout ; python_version < "3.11"
55
colorlog
66
cryptography

0 commit comments

Comments
 (0)