chore: format with ruff

container/healthcheck.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from http import HTTPStatus

performance-test/rest-proxy-produce-consume-test.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from kafka.admin import KafkaAdminClient, NewTopic
 from kafka.errors import TopicAlreadyExistsError
 from locust import FastHttpUser, task

performance-test/schema-registry-schema-post.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from dataclasses import dataclass, field
 from locust import FastHttpUser, task
 from locust.contrib.fasthttp import ResponseContextManager

setup.py

@@ -3,6 +3,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from setuptools import Extension, setup
 
 setup(

src/karapace/anonymize_schemas/anonymize_avro.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from typing import Any, TypeAlias, Union
 
 import hashlib

src/karapace/auth.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from base64 import b64encode
@@ -98,26 +99,21 @@ class AuthData(TypedDict):
 
 
 class AuthenticateProtocol(Protocol):
-    def authenticate(self, *, username: str, password: str) -> User | None:
-        ...
+    def authenticate(self, *, username: str, password: str) -> User | None: ...
 
 
 class AuthorizeProtocol(Protocol):
-    def get_user(self, username: str) -> User | None:
-        ...
+    def get_user(self, username: str) -> User | None: ...
 
-    def check_authorization(self, user: User | None, operation: Operation, resource: str) -> bool:
-        ...
+    def check_authorization(self, user: User | None, operation: Operation, resource: str) -> bool: ...
 
-    def check_authorization_any(self, user: User | None, operation: Operation, resources: list[str]) -> bool:
-        ...
+    def check_authorization_any(self, user: User | None, operation: Operation, resources: list[str]) -> bool: ...
 
 
 class AuthenticatorAndAuthorizer(AuthenticateProtocol, AuthorizeProtocol):
     MUST_AUTHENTICATE: bool = True
 
-    async def close(self) -> None:
-        ...
+    async def close(self) -> None: ...
 
     async def start(self, stats: StatsClient) -> None:  # pylint: disable=unused-argument
         ...

src/karapace/avro_dataclasses/introspect.py

@@ -20,16 +20,13 @@
     from _typeshed import DataclassInstance
 else:
 
-    class DataclassInstance:
-        ...
+    class DataclassInstance: ...
 
 
-class UnsupportedAnnotation(NotImplementedError):
-    ...
+class UnsupportedAnnotation(NotImplementedError): ...
 
 
-class UnderspecifiedAnnotation(UnsupportedAnnotation):
-    ...
+class UnderspecifiedAnnotation(UnsupportedAnnotation): ...
 
 
 def _field_type_array(field: Field, origin: type, type_: object) -> AvroType:

src/karapace/avro_dataclasses/models.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from .introspect import record_schema
@@ -22,8 +23,7 @@
     from _typeshed import DataclassInstance
 else:
 
-    class DataclassInstance:
-        ...
+    class DataclassInstance: ...
 
 
 __all__ = ("AvroModel",)

src/karapace/avro_dataclasses/schema.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Mapping

src/karapace/backup/api.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from .backends.reader import BaseBackupReader, BaseItemsBackupReader, ProducerSend, RestoreTopic, RestoreTopicLegacy

src/karapace/backup/backends/reader.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Callable, Generator, Iterator, Mapping, Sequence
@@ -78,8 +79,7 @@ def __init__(
 
     @staticmethod
     @abc.abstractmethod
-    def items_from_file(fp: IO[str]) -> Iterator[Sequence[str]]:
-        ...
+    def items_from_file(fp: IO[str]) -> Iterator[Sequence[str]]: ...
 
     def read(
         self,

src/karapace/backup/backends/v1.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Generator

src/karapace/backup/backends/v2.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Generator, Sequence

src/karapace/backup/backends/v3/backend.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from .checksum import RunningChecksum

src/karapace/backup/backends/v3/checksum.py

@@ -2,14 +2,13 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from typing import Protocol
 
 
 class RunningChecksum(Protocol):
-    def update(self, data: bytes) -> None:
-        ...
+    def update(self, data: bytes) -> None: ...
 
-    def digest(self) -> bytes:
-        ...
+    def digest(self) -> bytes: ...

src/karapace/backup/backends/v3/constants.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from typing import Final
 
 V3_MARKER: Final = b"/V3\n"

src/karapace/backup/backends/v3/readers.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from .checksum import RunningChecksum

src/karapace/backup/backends/v3/schema.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from collections.abc import Mapping
 from dataclasses import field
 from karapace.avro_dataclasses.models import AvroModel

src/karapace/backup/backends/v3/schema_tool.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from . import schema
 from avro.compatibility import ReaderWriterCompatibilityChecker, SchemaCompatibilityType
 from collections.abc import Generator

src/karapace/backup/backends/v3/writers.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from .checksum import RunningChecksum
 from .constants import V3_MARKER
 from .errors import IntegerAboveBound, IntegerBelowBound

src/karapace/backup/backends/writer.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Iterator, Mapping, Sequence
@@ -170,5 +171,4 @@ def store_record(
     def serialize_record(
         key_bytes: bytes | None,
         value_bytes: bytes | None,
-    ) -> str:
-        ...
+    ) -> str: ...

src/karapace/backup/cli.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from . import api

src/karapace/backup/encoders.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from karapace.key_format import KeyFormatter

src/karapace/backup/errors.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from confluent_kafka import TopicPartition
 from karapace.backup.poll_timeout import PollTimeout
 
@@ -12,8 +13,7 @@ class BackupError(Exception):
     """Baseclass for all backup errors."""
 
 
-class EmptyPartition(BackupError):
-    ...
+class EmptyPartition(BackupError): ...
 
 
 class PartitionCountError(BackupError):

src/karapace/backup/poll_timeout.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from datetime import timedelta

src/karapace/backup/safe_writer.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Generator
@@ -19,8 +20,7 @@
 std_out_alias: Final = ("", "-")
 
 
-class OverwriteRefused(Exception):
-    ...
+class OverwriteRefused(Exception): ...
 
 
 def _check_destination_file(destination: Path, allow_overwrite: bool) -> None:

src/karapace/backup/topic_configurations.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Container

src/karapace/client.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from aiohttp import BasicAuth, ClientSession
 from collections.abc import Awaitable, Callable, Mapping
 from karapace.typing import JsonData

src/karapace/compatibility/__init__.py

@@ -4,6 +4,7 @@
 Copyright (c) 2019 Aiven Ltd
 See LICENSE for details
 """
+
 from enum import Enum, unique
 
 import logging

src/karapace/compatibility/jsonschema/checks.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from avro.compatibility import merge, SchemaCompatibilityResult, SchemaCompatibilityType, SchemaIncompatibilityType

src/karapace/compatibility/jsonschema/types.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from collections.abc import Callable
 from dataclasses import dataclass
 from enum import Enum, unique

src/karapace/compatibility/jsonschema/utils.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from copy import copy
 from jsonschema import Draft7Validator
 from karapace.compatibility.jsonschema.types import BooleanSchema, Instance, Keyword, Subschema

src/karapace/compatibility/protobuf/checks.py

@@ -2,6 +2,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from avro.compatibility import SchemaCompatibilityResult, SchemaCompatibilityType
 from karapace.protobuf.compare_result import CompareResult
 from karapace.protobuf.schema import ProtobufSchema

src/karapace/compatibility/schema_compatibility.py

@@ -2,6 +2,7 @@
 Copyright (c) 2024 Aiven Ltd
 See LICENSE for details
 """
+
 from avro.compatibility import (
     merge,
     ReaderWriterCompatibilityChecker as AvroChecker,

src/karapace/config.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from collections.abc import Mapping

src/karapace/constants.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from typing import Final
 
 SCHEMA_TOPIC_NUM_PARTITIONS: Final = 1

src/karapace/coordinator/master_coordinator.py

@@ -4,6 +4,7 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+
 from __future__ import annotations
 
 from aiokafka import AIOKafkaClient