chore: pyugrade 3.10 plus

src/karapace/anonymize_schemas/anonymize_avro.py

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

src/karapace/avro_dataclasses/introspect.py

@@ -10,7 +10,8 @@
 from dataclasses import Field, fields, is_dataclass, MISSING
 from enum import Enum
 from functools import lru_cache
-from typing import Final, get_args, get_origin, TYPE_CHECKING, TypeVar, Union
+from types import UnionType
+from typing import Final, get_args, get_origin, TYPE_CHECKING, TypeVar
 
 import datetime
 import uuid
@@ -90,7 +91,7 @@ def _field_type(field: Field, type_: object) -> AvroType:  # pylint: disable=too
     origin = get_origin(type_)
 
     # Handle union types.
-    if origin is Union:
+    if origin is UnionType:
         return [_field_type(field, unit) for unit in get_args(type_)]  # type: ignore[misc]
 
     # Handle array types.

src/karapace/avro_dataclasses/models.py

@@ -5,12 +5,12 @@
 from __future__ import annotations
 
 from .introspect import record_schema
-from collections.abc import Iterable, Mapping
+from collections.abc import Callable, Iterable, Mapping
 from dataclasses import asdict, fields, is_dataclass
 from enum import Enum
 from functools import lru_cache, partial
-from typing import Callable, cast, IO, TYPE_CHECKING, TypeVar, Union
-from typing_extensions import get_args, get_origin, Self
+from typing import cast, get_args, get_origin, IO, TYPE_CHECKING, TypeVar, Union
+from typing_extensions import Self
 
 import avro
 import avro.io

src/karapace/avro_dataclasses/schema.py

@@ -5,8 +5,8 @@
 from __future__ import annotations
 
 from collections.abc import Mapping
-from typing import Literal
-from typing_extensions import NotRequired, TypeAlias, TypedDict
+from typing import Literal, TypeAlias
+from typing_extensions import NotRequired, TypedDict
 
 Primitive: TypeAlias = Literal["int", "long", "string", "null", "bytes", "boolean"]
 LogicalType: TypeAlias = Literal["timestamp-millis", "uuid"]

src/karapace/backup/api.py

@@ -22,7 +22,7 @@
 from .poll_timeout import PollTimeout
 from .topic_configurations import ConfigSource, get_topic_configurations
 from aiokafka.errors import KafkaError, TopicAlreadyExistsError
-from collections.abc import Iterator, Mapping, Sized
+from collections.abc import Callable, Iterator, Mapping, Sized
 from concurrent.futures import Future
 from confluent_kafka import Message, TopicPartition
 from enum import Enum
@@ -42,7 +42,7 @@
 from pathlib import Path
 from rich.console import Console
 from tenacity import retry, retry_if_exception_type, RetryCallState, stop_after_delay, wait_fixed
-from typing import Callable, Literal, NewType, TypeVar
+from typing import Literal, NewType, TypeVar
 
 import contextlib
 import datetime

src/karapace/backup/backends/reader.py

@@ -4,12 +4,11 @@
 """
 from __future__ import annotations
 
-from collections.abc import Generator, Iterator, Mapping, Sequence
+from collections.abc import Callable, Generator, Iterator, Mapping, Sequence
 from karapace.dataclasses import default_dataclass
 from karapace.typing import JsonData, JsonObject
 from pathlib import Path
-from typing import Callable, ClassVar, Final, IO, Optional, TypeVar, Union
-from typing_extensions import TypeAlias
+from typing import ClassVar, Final, IO, Optional, TypeAlias, TypeVar, Union
 
 import abc
 

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

@@ -9,7 +9,7 @@
 from .readers import read_metadata, read_records
 from .schema import ChecksumAlgorithm, DataFile, Header, Metadata, Record
 from .writers import write_metadata, write_record
-from collections.abc import Generator, Iterator, Mapping, Sequence
+from collections.abc import Callable, Generator, Iterator, Mapping, Sequence
 from confluent_kafka import Message
 from dataclasses import dataclass
 from karapace.backup.backends.reader import BaseBackupReader, Instruction, ProducerSend, RestoreTopic
@@ -19,8 +19,7 @@
 from karapace.utils import assert_never
 from karapace.version import __version__
 from pathlib import Path
-from typing import Callable, ContextManager, Final, IO, TypeVar
-from typing_extensions import TypeAlias
+from typing import ContextManager, Final, IO, TypeAlias, TypeVar
 
 import datetime
 import io

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

@@ -8,7 +8,6 @@
 from dataclasses import field
 from karapace.avro_dataclasses.models import AvroModel
 from karapace.dataclasses import default_dataclass
-from typing import Optional
 
 import datetime
 import enum
@@ -53,7 +52,7 @@ class Metadata(AvroModel):
     finished_at: datetime.datetime
     record_count: int = field(metadata={"type": "int"})
     topic_name: str
-    topic_id: Optional[uuid.UUID]
+    topic_id: uuid.UUID | None
     partition_count: int = field(metadata={"type": "int"})
     replication_factor: int = field(metadata={"type": "int"})
     topic_configurations: Mapping[str, str]
@@ -77,8 +76,8 @@ class Header(AvroModel):
 
 @default_dataclass
 class Record(AvroModel):
-    key: Optional[bytes]
-    value: Optional[bytes]
+    key: bytes | None
+    value: bytes | None
     headers: tuple[Header, ...]
     offset: int = field(metadata={"type": "long"})
     timestamp: int = field(metadata={"type": "long"})
@@ -87,7 +86,7 @@ class Record(AvroModel):
     # of records. When restoring, we accumulate parsed records until
     # encountering a checkpoint, verify the running checksum against it, and
     # only then produce the verified records to Kafka.
-    checksum_checkpoint: Optional[bytes]
+    checksum_checkpoint: bytes | None
 
     def __post_init__(self) -> None:
         assert self.offset >= 0

src/karapace/backup/backends/writer.py

@@ -8,8 +8,7 @@
 from confluent_kafka import Message
 from karapace.backup.safe_writer import bytes_writer, str_writer
 from pathlib import Path
-from typing import ContextManager, Generic, IO, Literal, TypeVar
-from typing_extensions import TypeAlias
+from typing import ContextManager, Generic, IO, Literal, TypeAlias, TypeVar
 
 import abc
 import contextlib

src/karapace/backup/safe_writer.py

@@ -7,8 +7,7 @@
 from collections.abc import Generator
 from pathlib import Path
 from tempfile import mkstemp, TemporaryDirectory
-from typing import Final, IO, Literal
-from typing_extensions import TypeAlias
+from typing import Final, IO, Literal, TypeAlias
 
 import contextlib
 import os

src/karapace/client.py

@@ -5,9 +5,8 @@
 See LICENSE for details
 """
 from aiohttp import BasicAuth, ClientSession
-from collections.abc import Awaitable, Mapping
+from collections.abc import Awaitable, Callable, Mapping
 from karapace.typing import JsonData
-from typing import Callable, Optional, Union
 from urllib.parse import urljoin
 
 import logging
@@ -19,7 +18,7 @@
 LOG = logging.getLogger(__name__)
 
 
-async def _get_aiohttp_client(*, auth: Optional[BasicAuth] = None) -> ClientSession:
+async def _get_aiohttp_client(*, auth: BasicAuth | None = None) -> ClientSession:
     return ClientSession(auth=auth)
 
 
@@ -28,7 +27,7 @@ def __init__(
         self,
         status: int,
         json_result: JsonData,
-        headers: Optional[Mapping] = None,
+        headers: Mapping | None = None,
     ) -> None:
         self.status_code = status
         self.json_result = json_result
@@ -48,10 +47,10 @@ def ok(self) -> bool:
 class Client:
     def __init__(
         self,
-        server_uri: Optional[str] = None,
+        server_uri: str | None = None,
         client_factory: Callable[..., Awaitable[ClientSession]] = _get_aiohttp_client,
-        server_ca: Optional[str] = None,
-        session_auth: Optional[BasicAuth] = None,
+        server_ca: str | None = None,
+        session_auth: BasicAuth | None = None,
     ) -> None:
         self.server_uri = server_uri or ""
         self.session_auth = session_auth
@@ -61,13 +60,13 @@ def __init__(
         # Instead we wait for the first query in async context and lazy-initialize aiohttp client.
         self.client_factory = client_factory
 
-        self.ssl_mode: Union[None, bool, ssl.SSLContext]
+        self.ssl_mode: None | bool | ssl.SSLContext
         if server_ca is None:
             self.ssl_mode = False
         else:
             self.ssl_mode = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
             self.ssl_mode.load_verify_locations(cafile=server_ca)
-        self._client: Optional[ClientSession] = None
+        self._client: ClientSession | None = None
 
     def path_for(self, path: Path) -> str:
         return urljoin(self.server_uri, path)
@@ -89,9 +88,9 @@ async def get(
         self,
         path: Path,
         json: JsonData = None,
-        headers: Optional[Headers] = None,
-        auth: Optional[BasicAuth] = None,
-        params: Optional[Mapping[str, str]] = None,
+        headers: Headers | None = None,
+        auth: BasicAuth | None = None,
+        params: Mapping[str, str] | None = None,
         json_response: bool = True,
     ) -> Result:
         path = self.path_for(path)
@@ -113,8 +112,8 @@ async def get(
     async def delete(
         self,
         path: Path,
-        headers: Optional[Headers] = None,
-        auth: Optional[BasicAuth] = None,
+        headers: Headers | None = None,
+        auth: BasicAuth | None = None,
     ) -> Result:
         path = self.path_for(path)
         if not headers:
@@ -133,8 +132,8 @@ async def post(
         self,
         path: Path,
         json: JsonData,
-        headers: Optional[Headers] = None,
-        auth: Optional[BasicAuth] = None,
+        headers: Headers | None = None,
+        auth: BasicAuth | None = None,
     ) -> Result:
         path = self.path_for(path)
         if not headers:
@@ -155,8 +154,8 @@ async def put(
         self,
         path: Path,
         json: JsonData,
-        headers: Optional[Headers] = None,
-        auth: Optional[BasicAuth] = None,
+        headers: Headers | None = None,
+        auth: BasicAuth | None = None,
     ) -> Result:
         path = self.path_for(path)
         if not headers:
@@ -177,8 +176,8 @@ async def put_with_data(
         self,
         path: Path,
         data: JsonData,
-        headers: Optional[Headers],
-        auth: Optional[BasicAuth] = None,
+        headers: Headers | None,
+        auth: BasicAuth | None = None,
     ) -> Result:
         path = self.path_for(path)
         client = await self.get_client()

src/karapace/compatibility/jsonschema/types.py

@@ -2,9 +2,10 @@
 Copyright (c) 2023 Aiven Ltd
 See LICENSE for details
 """
+from collections.abc import Callable
 from dataclasses import dataclass
 from enum import Enum, unique
-from typing import Callable, Generic, TypeVar
+from typing import Generic, TypeVar
 
 T = TypeVar("T")
 

src/karapace/compatibility/jsonschema/utils.py

@@ -5,7 +5,7 @@
 from copy import copy
 from jsonschema import Draft7Validator
 from karapace.compatibility.jsonschema.types import BooleanSchema, Instance, Keyword, Subschema
-from typing import Any, Optional, TypeVar, Union
+from typing import Any, TypeVar, Union
 
 import re
 
@@ -53,7 +53,7 @@ def normalize_schema_rec(validator: Draft7Validator, original_schema: Any) -> An
     return normalized
 
 
-def maybe_get_subschemas_and_type(schema: Any) -> Optional[tuple[list[Any], Subschema]]:
+def maybe_get_subschemas_and_type(schema: Any) -> tuple[list[Any], Subschema] | None:
     """If schema contains `anyOf`, `allOf`, or `oneOf`, return it.
 
     This will also normalized schemas with a list of types to a `anyOf`, e..g:
@@ -218,7 +218,7 @@ def is_tuple_without_additional_items(schema: Any) -> bool:
     return is_tuple(schema) and is_false_schema(additional_items)
 
 
-def gt(left: Optional[int], right: Optional[int]) -> bool:
+def gt(left: int | None, right: int | None) -> bool:
     """Predicate greater-than that checks for nullables.
 
     When `left` is writer and `right` is reader, this can be used to check for
@@ -256,11 +256,11 @@ def gt(left: Optional[int], right: Optional[int]) -> bool:
     return bool(left is not None and right is not None and left > right)
 
 
-def lt(left: Optional[int], right: Optional[int]) -> bool:
+def lt(left: int | None, right: int | None) -> bool:
     return gt(right, left)  # pylint: disable=arguments-out-of-order
 
 
-def ne(writer: Optional[T], reader: Optional[T]) -> bool:
+def ne(writer: T | None, reader: T | None) -> bool:
     """Predicate not-equals that checks for nullables.
 
     Predicate used to check for incompatibility in constraints that accept
@@ -288,7 +288,7 @@ def ne(writer: Optional[T], reader: Optional[T]) -> bool:
     return bool(reader is not None and writer is not None and reader != writer)
 
 
-def introduced_constraint(reader: Optional[T], writer: Optional[T]) -> bool:
+def introduced_constraint(reader: T | None, writer: T | None) -> bool:
     """True if `writer` did *not* have the constraint but `reader` introduced it.
 
     A constraint limits the value domain, because of that objects that were

src/karapace/instrumentation/prometheus.py

@@ -9,10 +9,10 @@
 from __future__ import annotations
 
 from aiohttp.web import middleware, Request, Response
-from collections.abc import Awaitable
+from collections.abc import Awaitable, Callable
 from karapace.rapu import RestApp
 from prometheus_client import CollectorRegistry, Counter, Gauge, generate_latest, Histogram
-from typing import Callable, Final
+from typing import Final
 
 import logging
 import time

src/karapace/kafka/common.py

@@ -14,10 +14,10 @@
     KafkaUnavailableError,
     NoBrokersAvailable,
 )
-from collections.abc import Iterable
+from collections.abc import Callable, Iterable
 from concurrent.futures import Future
 from confluent_kafka.error import KafkaError, KafkaException
-from typing import Any, Callable, Literal, NoReturn, Protocol, TypedDict, TypeVar
+from typing import Any, Literal, NoReturn, Protocol, TypedDict, TypeVar
 from typing_extensions import Unpack
 
 import logging

src/karapace/kafka/consumer.py

@@ -6,12 +6,12 @@
 from __future__ import annotations
 
 from aiokafka.errors import IllegalStateError, KafkaTimeoutError
-from collections.abc import Iterable
+from collections.abc import Callable, Iterable
 from confluent_kafka import Consumer, Message, TopicPartition
 from confluent_kafka.admin import PartitionMetadata
 from confluent_kafka.error import KafkaException
 from karapace.kafka.common import _KafkaConfigMixin, KafkaClientParams, raise_from_kafkaexception
-from typing import Any, Callable, TypeVar
+from typing import Any, TypeVar
 from typing_extensions import Unpack
 
 import asyncio