[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

.github/workflows/check_release_tag.py

@@ -1,4 +1,5 @@
 """Check that the GitHub release tag matches the package version."""
+
 import argparse
 import pathlib
 import re

disk_objectstore/container.py

@@ -1,6 +1,7 @@
 """
 The main implementation of the ``Container`` class of the object store.
 """
+
 # pylint: disable=too-many-lines
 import dataclasses
 import io
@@ -176,14 +177,12 @@ def _get_config_file(self) -> Path:
     @overload
     def _get_session(
         self, create: bool = False, raise_if_missing: Literal[True] = True
-    ) -> Session:
-        ...
+    ) -> Session: ...
 
     @overload
     def _get_session(
         self, create: bool = False, raise_if_missing: Literal[False] = False
-    ) -> Optional[Session]:
-        ...
+    ) -> Optional[Session]: ...
 
     def _get_session(
         self, create: bool = False, raise_if_missing: bool = False
@@ -521,17 +520,15 @@ def _get_objects_stream_meta_generator(
         hashkeys: Sequence[str],
         skip_if_missing: bool,
         with_streams: Literal[False],
-    ) -> Iterator[Tuple[str, ObjectMeta]]:
-        ...
+    ) -> Iterator[Tuple[str, ObjectMeta]]: ...
 
     @overload
     def _get_objects_stream_meta_generator(
         self,
         hashkeys: Sequence[str],
         skip_if_missing: bool,
         with_streams: Literal[True],
-    ) -> Iterator[Tuple[str, Optional[StreamSeekBytesType], ObjectMeta]]:
-        ...
+    ) -> Iterator[Tuple[str, Optional[StreamSeekBytesType], ObjectMeta]]: ...
 
     def _get_objects_stream_meta_generator(  # pylint: disable=too-many-branches,too-many-statements,too-many-locals
         self,
@@ -2653,9 +2650,9 @@ def repack_pack(  # pylint: disable=too-many-branches,too-many-statements
                     source_compressed,
                 ) in session.execute(stmt):
                     # This is the read handle of the bytes in the pack - it might be
-                    read_handle: Union[
-                        PackedObjectReader, ZlibStreamDecompresser
-                    ] = PackedObjectReader(read_pack, offset, length)
+                    read_handle: Union[PackedObjectReader, ZlibStreamDecompresser] = (
+                        PackedObjectReader(read_pack, offset, length)
+                    )
 
                     # Determine if I should compress or not the destination - this function will
                     # try to do it in a cheap way (e.g. if the source is already compressed, will just

disk_objectstore/database.py

@@ -1,4 +1,5 @@
 """Models for the container index file (SQLite DB)."""
+
 from pathlib import Path
 from typing import Optional
 

disk_objectstore/dataclasses.py

@@ -2,6 +2,7 @@
 Definition of the dataclasses used as return values of
 a number of methods.
 """
+
 from dataclasses import asdict, dataclass
 from typing import TYPE_CHECKING, List, Optional, Union
 

disk_objectstore/utils.py

@@ -3,6 +3,7 @@
 Some might be useful also for end users, like the wrappers to get streams,
 like the ``LazyOpener``.
 """
+
 #  pylint: disable= too-many-lines
 from __future__ import annotations
 
@@ -809,9 +810,9 @@ def __init__(
         self._decompressor = self.decompressobj_class()
         self._internal_buffer = b""
         self._pos = 0
-        self._lazy_uncompressed_stream: None | (
-            LazyLooseStream
-        ) = lazy_uncompressed_stream
+        self._lazy_uncompressed_stream: None | (LazyLooseStream) = (
+            lazy_uncompressed_stream
+        )
         # If True, this class just proxies request to the underlying
         # uncompressed stream
         self._use_uncompressed_stream: bool = False
@@ -1326,11 +1327,9 @@ def safe_flush_to_disk(
     fhandle.flush()
 
     # Default fsync function, replaced on Mac OS X
-    _fsync_function: Callable[
-        [Any], Any
-    ] = lambda fileno: os.fsync(  # pylint: disable=unnecessary-lambda
+    _fsync_function: Callable[[Any], Any] = lambda fileno: os.fsync(
         fileno
-    )
+    )  # pylint: disable=unnecessary-lambda
 
     # Flush to disk
     if hasattr(fcntl, "F_FULLFSYNC") is not None and (

tests/conftest.py

@@ -1,4 +1,5 @@
 """Configuration file for pytest tests."""
+
 import hashlib
 import os
 import random

tests/test_basic.py

@@ -2,6 +2,7 @@
 
 This is also a way to verify the behavior of the underlying OS/filesystem.
 """
+
 import os
 import subprocess
 import sys

tests/test_benchmark.py

@@ -1,4 +1,5 @@
 """Test the performance of the container implementation."""
+
 import hashlib
 import random
 

tests/test_cli.py

@@ -1,4 +1,5 @@
 """Test the CLI commands"""
+
 import platform
 from pathlib import Path
 

tests/test_concurrency.py

@@ -1,4 +1,5 @@
 """Test of the object-store container module."""
+
 import os
 import subprocess
 import sys