fix fo E261 at least two spaces before inline comment
This commit is contained in:
@@ -45,7 +45,7 @@ class CollectionBase(storage.BaseCollection):
|
|||||||
self._filesystem_path = filesystem_path
|
self._filesystem_path = filesystem_path
|
||||||
|
|
||||||
# TODO: better fix for "mypy"
|
# TODO: better fix for "mypy"
|
||||||
@types.contextmanager # type: ignore
|
@types.contextmanager # type: ignore
|
||||||
def _atomic_write(self, path: str, mode: str = "w",
|
def _atomic_write(self, path: str, mode: str = "w",
|
||||||
newline: Optional[str] = None) -> Iterator[IO[AnyStr]]:
|
newline: Optional[str] = None) -> Iterator[IO[AnyStr]]:
|
||||||
# TODO: Overload with Literal when dropping support for Python < 3.8
|
# TODO: Overload with Literal when dropping support for Python < 3.8
|
||||||
|
|||||||
@@ -87,7 +87,7 @@ class CollectionPartCache(CollectionBase):
|
|||||||
self._storage._makedirs_synced(cache_folder)
|
self._storage._makedirs_synced(cache_folder)
|
||||||
# Race: Other processes might have created and locked the file.
|
# Race: Other processes might have created and locked the file.
|
||||||
# TODO: better fix for "mypy"
|
# TODO: better fix for "mypy"
|
||||||
with contextlib.suppress(PermissionError), self._atomic_write( # type: ignore
|
with contextlib.suppress(PermissionError), self._atomic_write( # type: ignore
|
||||||
os.path.join(cache_folder, href), "wb") as fo:
|
os.path.join(cache_folder, href), "wb") as fo:
|
||||||
fb = cast(BinaryIO, fo)
|
fb = cast(BinaryIO, fo)
|
||||||
pickle.dump((cache_hash, *content), fb)
|
pickle.dump((cache_hash, *content), fb)
|
||||||
|
|||||||
@@ -62,6 +62,6 @@ class CollectionPartMeta(CollectionBase):
|
|||||||
|
|
||||||
def set_meta(self, props: Mapping[str, str]) -> None:
|
def set_meta(self, props: Mapping[str, str]) -> None:
|
||||||
# TODO: better fix for "mypy"
|
# TODO: better fix for "mypy"
|
||||||
with self._atomic_write(self._props_path, "w") as fo: # type: ignore
|
with self._atomic_write(self._props_path, "w") as fo: # type: ignore
|
||||||
f = cast(TextIO, fo)
|
f = cast(TextIO, fo)
|
||||||
json.dump(props, f, sort_keys=True)
|
json.dump(props, f, sort_keys=True)
|
||||||
|
|||||||
@@ -96,7 +96,7 @@ class CollectionPartSync(CollectionPartCache, CollectionPartHistory,
|
|||||||
try:
|
try:
|
||||||
# Race: Other processes might have created and locked the file.
|
# Race: Other processes might have created and locked the file.
|
||||||
# TODO: better fix for "mypy"
|
# TODO: better fix for "mypy"
|
||||||
with self._atomic_write(token_path, "wb") as fo: # type: ignore
|
with self._atomic_write(token_path, "wb") as fo: # type: ignore
|
||||||
fb = cast(BinaryIO, fo)
|
fb = cast(BinaryIO, fo)
|
||||||
pickle.dump(state, fb)
|
pickle.dump(state, fb)
|
||||||
except PermissionError:
|
except PermissionError:
|
||||||
|
|||||||
@@ -44,7 +44,7 @@ class CollectionPartUpload(CollectionPartGet, CollectionPartCache,
|
|||||||
(href, self.path, e)) from e
|
(href, self.path, e)) from e
|
||||||
path = pathutils.path_to_filesystem(self._filesystem_path, href)
|
path = pathutils.path_to_filesystem(self._filesystem_path, href)
|
||||||
# TODO: better fix for "mypy"
|
# TODO: better fix for "mypy"
|
||||||
with self._atomic_write(path, newline="") as fo: # type: ignore
|
with self._atomic_write(path, newline="") as fo: # type: ignore
|
||||||
f = cast(TextIO, fo)
|
f = cast(TextIO, fo)
|
||||||
f.write(item.serialize())
|
f.write(item.serialize())
|
||||||
# Clean the cache after the actual item is stored, or the cache entry
|
# Clean the cache after the actual item is stored, or the cache entry
|
||||||
|
|||||||
Reference in New Issue
Block a user