ruff fml.

aio-libs · Nov 16, 2024 · d7b5abf · d7b5abf
1 parent 7662b0e
commit d7b5abf
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 11 deletions.
diff --git a/aiokafka/cluster.pyi b/aiokafka/cluster.pyi
@@ -18,13 +18,15 @@ from aiokafka.protocol.metadata import (
 from aiokafka.structs import BrokerMetadata, PartitionMetadata, TopicPartition
 
 log = ...
-MetadataResponse = MetadataResponse_v0 |\
-    MetadataResponse_v1 |\
-    MetadataResponse_v2 |\
-    MetadataResponse_v3 |\
-    MetadataResponse_v4 |\
-    MetadataResponse_v5
-GroupCoordinatorResponse =  GroupCoordinatorResponse_v0 | GroupCoordinatorResponse_v1
+MetadataResponse = (
+    MetadataResponse_v0
+    | MetadataResponse_v1
+    | MetadataResponse_v2
+    | MetadataResponse_v3
+    | MetadataResponse_v4
+    | MetadataResponse_v5
+)
+GroupCoordinatorResponse = GroupCoordinatorResponse_v0 | GroupCoordinatorResponse_v1
 
 class ClusterConfig(TypedDict):
     retry_backoff_ms: int

diff --git a/aiokafka/errors.pyi b/aiokafka/errors.pyi
@@ -134,14 +134,12 @@ class ConsumerStoppedError(Exception):
     ones.
     """
 
-
 class IllegalOperation(Exception):
     """Raised if you try to execute an operation, that is not available with
     current configuration. For example trying to commit if no group_id was
     given.
     """
 
-
 class NoOffsetForPartitionError(KafkaError): ...
 class RecordTooLargeError(KafkaError): ...
 class ProducerClosed(KafkaError): ...

diff --git a/aiokafka/protocol/metadata.pyi b/aiokafka/protocol/metadata.pyi
@@ -39,6 +39,5 @@ class MetadataRequest_v5(Request):
     An additional field for offline_replicas has been added to the v5 metadata response
     """
 
-
 MetadataRequest = ...
 MetadataResponse = ...
diff --git a/aiokafka/protocol/types.pyi b/aiokafka/protocol/types.pyi
@@ -60,7 +60,7 @@ class Float64(AbstractType[float]):
 class String:
     def __init__(self, encoding: str = ...) -> None: ...
     def encode(self, value: str | None) -> bytes: ...
-    def decode(self, data: BytesIO) -> str| None: ...
+    def decode(self, data: BytesIO) -> str | None: ...
     @classmethod
     def repr(cls, value: str) -> str: ...