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

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

proto/hatch_build.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Dynamically generate protobuf python code."""
 
-
 from __future__ import annotations
 
 import os

src/ota_metadata/legacy/parser.py

@@ -36,7 +36,6 @@
 
 """
 
-
 from __future__ import annotations
 
 import atexit

src/ota_metadata/utils/cert_store.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Implementation of otaclient CA cert chain store."""
 
-
 from __future__ import annotations
 
 import logging

src/ota_proxy/cache_streaming.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Implementation of cache streaming."""
 
-
 from __future__ import annotations
 
 import asyncio

src/ota_proxy/db.py

@@ -116,7 +116,6 @@ def export_headers_to_client(self) -> CIMultiDict[str]:
 
 
 class CacheMetaORM(ORMBase[CacheMeta]):
-
     def cachemeta_create_indexes(self) -> None:
         _indexes = {
             "bucket_idx_index": CacheMeta.table_create_index_stmt(
@@ -138,7 +137,6 @@ def cachemeta_create_indexes(self) -> None:
 
 
 class AsyncCacheMetaORM(AsyncORMBase[CacheMeta]):
-
     async def rotate_cache(
         self, bucket_idx: int, num: int
     ) -> Optional[list[CacheMeta]]:

src/ota_proxy/external_cache.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Implementation of mounting/umounting external cache."""
 
-
 from __future__ import annotations
 
 import logging

src/ota_proxy/lru_cache_helper.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Implementation of OTA cache control."""
 
-
 from __future__ import annotations
 
 import bisect

src/ota_proxy/ota_cache.py

@@ -400,7 +400,9 @@ async def _do_request() -> AsyncIterator[bytes]:
                         yield data
 
         # open remote connection
-        resp_headers: CIMultiDictProxy[str] = await (_remote_fd := _do_request()).__anext__()  # type: ignore
+        resp_headers: CIMultiDictProxy[str] = await (
+            _remote_fd := _do_request()
+        ).__anext__()  # type: ignore
         return _remote_fd, resp_headers
 
     async def _retrieve_file_by_cache_lookup(

src/ota_proxy/server_app.py

@@ -92,7 +92,7 @@ def parse_raw_headers(raw_headers: List[Tuple[bytes, bytes]]) -> Dict[str, str]:
 
 
 def encode_headers(
-    headers: Union[CIMultiDict[str], CIMultiDictProxy[str]]
+    headers: Union[CIMultiDict[str], CIMultiDictProxy[str]],
 ) -> List[Tuple[bytes, bytes]]:
     """Encode headers dict to list of bytes tuples for sending back to client.
 

src/otaclient/_logging.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Configure the logging for otaclient."""
 
-
 from __future__ import annotations
 
 import atexit

src/otaclient/_otaproxy_ctx.py

@@ -16,7 +16,6 @@
 The API exposed by this module is meant to be controlled by otaproxy managing thread only.
 """
 
-
 from __future__ import annotations
 
 import asyncio

src/otaclient/_status_monitor.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """The implementation of tracking otaclient operation status."""
 
-
 from __future__ import annotations
 
 import atexit
@@ -72,7 +71,6 @@ class SetOTAClientMetaReport:
 
 @dataclass
 class UpdateProgressReport:
-
     class Type(Enum):
         # NOTE: PREPARE_LOCAL, DOWNLOAD_REMOTE and APPLY_DELTA are together
         #       counted as <processed_files_*>

src/otaclient/_types.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """OTAClient internal used types."""
 
-
 from __future__ import annotations
 
 import multiprocessing.synchronize as mp_sync

src/otaclient/_utils.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Common shared utils, only used by otaclient package."""
 
-
 from __future__ import annotations
 
 import itertools

src/otaclient/boot_control/_firmware_package.py

@@ -39,7 +39,6 @@
 ```
 """
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/boot_control/_grub.py

@@ -30,7 +30,6 @@
     still expecting new mechanism to fundamentally resolve this issue.
 """
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/boot_control/_jetson_cboot.py

@@ -16,7 +16,6 @@
 Supports BSP version < R34.
 """
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/boot_control/_jetson_common.py

@@ -16,7 +16,6 @@
 This module is shared by jetson-cboot and jetson-uefi bootloader type.
 """
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/boot_control/_jetson_uefi.py

@@ -17,7 +17,6 @@
 But firmware update is only supported after BSP R35.2.
 """
 
-
 from __future__ import annotations
 
 import contextlib

src/otaclient/boot_control/_ota_status_control.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Shared utils for boot_controller."""
 
-
 from __future__ import annotations
 
 import contextlib

src/otaclient/boot_control/_rpi_boot.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Boot control support for Raspberry pi 4 Model B."""
 
-
 from __future__ import annotations
 
 import contextlib

src/otaclient/boot_control/_slot_mnt_helper.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Helper for mounting/umount slots during OTA."""
 
-
 from __future__ import annotations
 
 import atexit

src/otaclient/configs/__init__.py

@@ -46,7 +46,6 @@ class DefaultOTAClientConfigs(ConfigurableSettings, Consts):
 else:
 
     class DefaultOTAClientConfigs:
-
         def __init__(self) -> None:
             self._cfg_consts = Consts()
             self._cfg_configurable = ConfigurableSettings()

src/otaclient/configs/_cfg_configurable.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Runtime configurable configs for otaclient."""
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/configs/_cfg_consts.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """otaclient internal uses consts, should not be changed from external."""
 
-
 from __future__ import annotations
 
 from otaclient_common import replace_root
@@ -29,7 +28,6 @@ class CreateStandbyMechanism(StrEnum):
 
 
 class Consts:
-
     CANONICAL_ROOT = CANONICAL_ROOT
 
     @property

src/otaclient/configs/_ecu_info.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """ECU metadatas definition and parsing logic."""
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/configs/_proxy_info.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """proxy_info.yaml definition and parsing logic."""
 
-
 from __future__ import annotations
 
 import logging

src/otaclient/configs/cfg.py

@@ -46,7 +46,6 @@ class _OTAClientConfigs(ConfigurableSettings, Consts):
 else:
 
     class _OTAClientConfigs:
-
         # NOTE(20241108): still use __getattr__ to allow changing/mocking attributes
         #   for easy testing.
         def __getattr__(self, name: str) -> Any:

src/otaclient/create_standby/common.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Common used helpers, classes and functions for different bank creating methods."""
 
-
 from __future__ import annotations
 
 import contextlib

src/otaclient/create_standby/interface.py

@@ -29,7 +29,6 @@
     update to the standby slot.
 """
 
-
 from __future__ import annotations
 
 from abc import abstractmethod

src/otaclient/errors.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """OTA error code definition"""
 
-
 from __future__ import annotations
 
 from enum import Enum, unique

src/otaclient/grpc/api_v2/ecu_status.py

@@ -36,7 +36,6 @@
     any_requires_network, all_success, in_update_ecus_id, failed_ecus_id, success_ecus_id and in_update_childecus_id.
 """
 
-
 from __future__ import annotations
 
 import asyncio
@@ -82,7 +81,6 @@ def discard(self, value: T):
 
 
 class ECUStatusStorage:
-
     def __init__(
         self,
         *,

src/otaclient/grpc/api_v2/ecu_tracker.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Tracker that queries and stores ECU status from all defined ECUs."""
 
-
 from __future__ import annotations
 
 import asyncio
@@ -48,7 +47,6 @@
 
 
 class ECUTracker:
-
     def __init__(
         self,
         ecu_status_storage: ECUStatusStorage,

src/otaclient/grpc/api_v2/main.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Main entry for OTA API v2 grpc server."""
 
-
 from __future__ import annotations
 
 import asyncio

src/otaclient/grpc/api_v2/servicer.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """OTA Service API v2 implementation."""
 
-
 from __future__ import annotations
 
 import asyncio

src/otaclient/grpc/api_v2/types.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Helpers for converting otaclient internal used types into api_v2 types."""
 
-
 from __future__ import annotations
 
 import time

src/otaclient/main.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Entrypoint of otaclient."""
 
-
 from __future__ import annotations
 
 import atexit

src/otaclient/ota_core.py

@@ -628,7 +628,6 @@ def execute(self):
 
 
 class OTAClient:
-
     def __init__(
         self,
         *,
@@ -840,7 +839,6 @@ def main(
                 )
 
             elif isinstance(request, UpdateRequestV2):
-
                 _update_thread = threading.Thread(
                     target=self.update,
                     args=[request],
@@ -877,7 +875,6 @@ def main(
                 )
                 _allow_request_after = _now + HOLD_REQ_HANDLING_ON_ACK_REQUEST
             else:
-
                 _err_msg = f"request is invalid: {request=}, {self._live_ota_status=}"
                 logger.error(_err_msg)
                 resp_queue.put_nowait(

src/otaclient_api/v2/api_caller.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """OTAClient API caller implementation."""
 
-
 from __future__ import annotations
 
 import grpc.aio

src/otaclient_api/v2/types.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Defined wrappers for otaclient_v2 protobuf message types."""
 
-
 from __future__ import annotations
 
 from abc import abstractmethod

src/otaclient_common/__init__.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Common shared libs for otaclient."""
 
-
 from __future__ import annotations
 
 import importlib.util

src/otaclient_common/_io.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 """Common shared helper functions for IO."""
 
-
 from __future__ import annotations
 
 import hashlib