X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=collect%2Fshared_dict.py;fp=collect%2Fshared_dict.py;h=e0a42f2c55c2fc865b0c89642d458ae26009c224;hb=713a609bd19d491de03debf8a4a6ddf2540b13dc;hp=ec76138b393955d47f3850bf2a91d425ada563b1;hpb=eb1c6392095947b3205c4d52cd9b1507e6cd776b;p=python_utils.git 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()