summaryrefslogtreecommitdiff
path: root/collect/shared_dict.py
diff options
context:
space:
mode:
Diffstat (limited to 'collect/shared_dict.py')
-rw-r--r--collect/shared_dict.py15
1 files changed, 2 insertions, 13 deletions
diff --git a/collect/shared_dict.py b/collect/shared_dict.py
index ec76138..e0a42f2 100644
--- a/collect/shared_dict.py
+++ b/collect/shared_dict.py
@@ -31,16 +31,7 @@ import pickle
from contextlib import contextmanager
from functools import wraps
from multiprocessing import RLock, shared_memory
-from typing import (
- Any,
- Dict,
- Generator,
- ItemsView,
- Iterator,
- KeysView,
- Optional,
- ValuesView,
-)
+from typing import Any, Dict, Generator, ItemsView, Iterator, KeysView, Optional, ValuesView
from decorator_utils import synchronized
@@ -94,9 +85,7 @@ class SharedDict(object):
return shared_memory.SharedMemory(name=name, create=True, size=size_bytes)
def _ensure_memory_initialization(self):
- memory_is_empty = (
- bytes(self.shared_memory.buf).split(SharedDict.NULL_BYTE, 1)[0] == b''
- )
+ memory_is_empty = bytes(self.shared_memory.buf).split(SharedDict.NULL_BYTE, 1)[0] == b''
if memory_is_empty:
self.clear()