diff options
| author | Maxim Devaev <[email protected]> | 2022-08-07 19:35:08 +0300 |
|---|---|---|
| committer | Maxim Devaev <[email protected]> | 2022-08-07 19:35:08 +0300 |
| commit | e37a7254d5cf7e4cfa5dcfbbaf5b0e9d7474d154 (patch) | |
| tree | c25210abfceb0da0725798105a389c5598694ff7 /kvmd/apps/janus/runner.py | |
| parent | fdc3edfa799b21f04a83676459bab7a4e67b056f (diff) | |
using shield_fg() in atomic (now atomic_fg)
Diffstat (limited to 'kvmd/apps/janus/runner.py')
| -rw-r--r-- | kvmd/apps/janus/runner.py | 4 |
1 files changed, 2 insertions, 2 deletions
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 ...") |