diff --git a/src/s5p/pool.py b/src/s5p/pool.py index d792928..cca803d 100644 --- a/src/s5p/pool.py +++ b/src/s5p/pool.py @@ -369,8 +369,7 @@ class ProxyPool: # report evicted proxies to upstream API if evict_keys and self._cfg.report_url: - dead = [k for k in evict_keys] - asyncio.ensure_future(self._report_dead(dead)) + asyncio.create_task(self._report_dead(list(evict_keys))) async def _report_dead(self, keys: list[str]) -> None: """POST dead proxy list to report_url (fire-and-forget, async).""" diff --git a/src/s5p/server.py b/src/s5p/server.py index 46fe2ad..a2d5bdc 100644 --- a/src/s5p/server.py +++ b/src/s5p/server.py @@ -292,7 +292,7 @@ async def serve(config: Config) -> None: logger.info("reload: config reloaded") def _on_sighup() -> None: - asyncio.ensure_future(_reload()) + asyncio.create_task(_reload()) loop.add_signal_handler(signal.SIGHUP, _on_sighup)