summaryrefslogtreecommitdiff
path: root/kvmd/aiomulti.py
diff options
context:
space:
mode:
authorDevaev Maxim <[email protected]>2020-10-13 13:50:01 +0300
committerDevaev Maxim <[email protected]>2020-10-13 13:50:01 +0300
commitc6524fc7ac3a271a91fef994a9a9529940337596 (patch)
tree5cef560dfac73d4143df893e0a5be21e344222a8 /kvmd/aiomulti.py
parent51ac65d542e041c4f75f0428fe4e84a10ef1c356 (diff)
typing fixes
Diffstat (limited to 'kvmd/aiomulti.py')
-rw-r--r--kvmd/aiomulti.py6
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()
}