From e37a7254d5cf7e4cfa5dcfbbaf5b0e9d7474d154 Mon Sep 17 00:00:00 2001 From: Maxim Devaev Date: Sun, 7 Aug 2022 19:35:08 +0300 Subject: using shield_fg() in atomic (now atomic_fg) --- kvmd/apps/janus/runner.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kvmd/apps/janus/runner.py') diff --git a/kvmd/apps/janus/runner.py b/kvmd/apps/janus/runner.py index 204f8a9e..799fd94c 100644 --- a/kvmd/apps/janus/runner.py +++ b/kvmd/apps/janus/runner.py @@ -126,13 +126,13 @@ class JanusRunner: # pylint: disable=too-many-instance-attributes # ===== - @aiotools.atomic + @aiotools.atomic_fg async def __start_janus(self, netcfg: _Netcfg) -> None: get_logger(0).info("Starting Janus ...") assert not self.__janus_task self.__janus_task = asyncio.create_task(self.__janus_task_loop(netcfg)) - @aiotools.atomic + @aiotools.atomic_fg async def __stop_janus(self) -> None: if self.__janus_task: get_logger(0).info("Stopping Janus ...") -- cgit v1.2.3