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

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

.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

@@ -183,14 +183,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
-    ) -> Session | None:
-        ...
+    ) -> Session | None: ...
 
     def _get_session(
         self, create: bool = False, raise_if_missing: bool = False
@@ -528,17 +526,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, StreamSeekBytesType | None, ObjectMeta]]:
-        ...
+    ) -> Iterator[tuple[str, StreamSeekBytesType | None, ObjectMeta]]: ...
 
     def _get_objects_stream_meta_generator(  # pylint: disable=too-many-branches,too-many-statements,too-many-locals
         self,
@@ -1323,8 +1319,9 @@ def pack_all_loose(  # pylint: disable=too-many-locals,too-many-branches,too-man
         compress: bool | CompressMode = CompressMode.NO,
         validate_objects: bool = True,
         do_fsync: bool = True,
-        callback: None
-        | (Callable[[Arg(str, "action"), Arg(Any, "value")], None]) = None,
+        callback: None | (
+            Callable[[Arg(str, "action"), Arg(Any, "value")], None]
+        ) = None,
     ) -> None:
         """Pack all loose objects.
 
@@ -2616,8 +2613,9 @@ def delete_objects(self, hashkeys: list[str]) -> list[str | Any]:
     def repack(
         self,
         compress_mode: CompressMode = CompressMode.KEEP,
-        callback: None
-        | (Callable[[Arg(str, "action"), Arg(Any, "value")], None]) = None,
+        callback: None | (
+            Callable[[Arg(str, "action"), Arg(Any, "value")], None]
+        ) = None,
     ) -> None:
         """Perform a repack of all packed objects.
 
@@ -2645,8 +2643,9 @@ def repack_pack(  # pylint: disable=too-many-branches,too-many-statements,too-ma
         self,
         pack_id: str,
         compress_mode: CompressMode = CompressMode.KEEP,
-        callback: None
-        | (Callable[[Arg(str, "action"), Arg(Any, "value")], None]) = None,
+        callback: None | (
+            Callable[[Arg(str, "action"), Arg(Any, "value")], None]
+        ) = None,
     ) -> None:
         """Perform a repack of a given pack object.
 
@@ -2723,9 +2722,9 @@ def repack_pack(  # pylint: disable=too-many-branches,too-many-statements,too-ma
                     source_compressed,
                 ) in session.execute(stmt):
                     # This is the read handle of the bytes in the pack - it might be
-                    read_handle: (
-                        PackedObjectReader | ZlibStreamDecompresser
-                    ) = PackedObjectReader(read_pack, offset, length)
+                    read_handle: 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

tests/test_container.py

@@ -1,4 +1,5 @@
 """Test of the object-store container module."""
+
 # pylint: disable=too-many-lines,protected-access
 import dataclasses
 import functools

tests/test_examples.py

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

tests/test_optional.py

@@ -1,5 +1,6 @@
 """Additional optional tests to check additional functionality, such as
 if the library works also with other external optional modules."""
+
 from pathlib import Path
 
 import numpy as np

tests/test_utils.py

@@ -1,4 +1,5 @@
 """Test of the utils wrappers."""
+
 # pylint: disable=too-many-lines,protected-access
 import functools
 import hashlib