diff options
author | Devaev Maxim <[email protected]> | 2020-10-13 13:50:01 +0300 |
---|---|---|
committer | Devaev Maxim <[email protected]> | 2020-10-13 13:50:01 +0300 |
commit | c6524fc7ac3a271a91fef994a9a9529940337596 (patch) | |
tree | 5cef560dfac73d4143df893e0a5be21e344222a8 /kvmd/aiomulti.py | |
parent | 51ac65d542e041c4f75f0428fe4e84a10ef1c356 (diff) |
typing fixes
Diffstat (limited to 'kvmd/aiomulti.py')
-rw-r--r-- | kvmd/aiomulti.py | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/kvmd/aiomulti.py b/kvmd/aiomulti.py index 9ff60d4c..edfc5c34 100644 --- a/kvmd/aiomulti.py +++ b/kvmd/aiomulti.py @@ -21,8 +21,6 @@ import multiprocessing -import multiprocessing.queues -import multiprocessing.sharedctypes import queue from typing import Dict @@ -33,7 +31,7 @@ from . import aiotools # ===== class AioProcessNotifier: def __init__(self) -> None: - self.__queue: multiprocessing.queues.Queue = multiprocessing.Queue() + self.__queue: "multiprocessing.Queue[None]" = multiprocessing.Queue() def notify(self) -> None: self.__queue.put_nowait(None) @@ -62,7 +60,7 @@ class AioSharedFlags: self.__notifier = notifier - self.__flags: Dict[str, multiprocessing.sharedctypes.RawValue] = { + self.__flags = { key: multiprocessing.RawValue("i", int(value)) # type: ignore for (key, value) in initial.items() } |