From 919327ec3e323f026b196cae61f97575d4400e14 Mon Sep 17 00:00:00 2001 From: jcass77 Date: Tue, 4 Aug 2020 05:16:17 +0200 Subject: [PATCH] refactor: Prefer using `create_task` to old style `ensure_future`. --- run_client.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/run_client.py b/run_client.py index d0ee5ae..b007e48 100644 --- a/run_client.py +++ b/run_client.py @@ -49,6 +49,7 @@ async def graceful_shutdown(pipeline, sig_name=None): if _shutting_down.is_set(): # Only try to shut down once + logger.warning(f"Shutdown already in progress! Ignoring signal '{sig_name}'.") return _shutting_down.set() @@ -82,7 +83,7 @@ async def main(): for sig_name in {"SIGINT", "SIGTERM"}: loop.add_signal_handler( getattr(signal, sig_name), - lambda: asyncio.ensure_future( + lambda: asyncio.create_task( graceful_shutdown(fix_pipeline, sig_name=sig_name) ), )