Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Aug 5, 2024
1 parent 89c425b commit 58bfbde
Show file tree
Hide file tree
Showing 14 changed files with 26 additions and 18 deletions.
1 change: 1 addition & 0 deletions .github/workflows/check_release_tag.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Check that the GitHub release tag matches the package version."""

import argparse
import pathlib
import re
Expand Down
19 changes: 8 additions & 11 deletions disk_objectstore/container.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
"""
The main implementation of the ``Container`` class of the object store.
"""

# pylint: disable=too-many-lines
import dataclasses
import io
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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,
Expand Down Expand Up @@ -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
Expand Down
1 change: 1 addition & 0 deletions disk_objectstore/database.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Models for the container index file (SQLite DB)."""

from pathlib import Path
from typing import Optional

Expand Down
1 change: 1 addition & 0 deletions disk_objectstore/dataclasses.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down
13 changes: 6 additions & 7 deletions disk_objectstore/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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 (
Expand Down
1 change: 1 addition & 0 deletions tests/conftest.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Configuration file for pytest tests."""

import hashlib
import os
import random
Expand Down
1 change: 1 addition & 0 deletions tests/test_basic.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
This is also a way to verify the behavior of the underlying OS/filesystem.
"""

import os
import subprocess
import sys
Expand Down
1 change: 1 addition & 0 deletions tests/test_benchmark.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Test the performance of the container implementation."""

import hashlib
import random

Expand Down
1 change: 1 addition & 0 deletions tests/test_cli.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Test the CLI commands"""

import platform
from pathlib import Path

Expand Down
1 change: 1 addition & 0 deletions tests/test_concurrency.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Test of the object-store container module."""

import os
import subprocess
import sys
Expand Down
1 change: 1 addition & 0 deletions tests/test_container.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Test of the object-store container module."""

# pylint: disable=too-many-lines,protected-access
import dataclasses
import functools
Expand Down
1 change: 1 addition & 0 deletions tests/test_examples.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Test of the object-store container module."""

import subprocess
import sys
import tempfile
Expand Down
1 change: 1 addition & 0 deletions tests/test_optional.py
Original file line number Diff line number Diff line change
@@ -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
Expand Down
1 change: 1 addition & 0 deletions tests/test_utils.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
"""Test of the utils wrappers."""

# pylint: disable=too-many-lines,protected-access
import functools
import hashlib
Expand Down

0 comments on commit 58bfbde

Please sign in to comment.