airtai · davorrunje · Nov 29, 2024 · Nov 25, 2024 · Nov 29, 2024
diff --git a/faststream/__init__.py b/faststream/__init__.py
@@ -8,23 +8,23 @@
 from faststream.utils import Context, Depends, Header, Path, apply_types, context
 
 __all__ = (
+    # middlewares
+    "BaseMiddleware",
+    "Context",
+    "ContextRepo",
+    "Depends",
+    "ExceptionMiddleware",
     # app
     "FastStream",
-    "TestApp",
-    # utils
-    "apply_types",
-    "context",
-    "Context",
     "Header",
-    "Path",
-    "Depends",
     # annotations
     "Logger",
-    "ContextRepo",
     "NoCast",
-    # middlewares
-    "BaseMiddleware",
-    "ExceptionMiddleware",
+    "Path",
     # basic
     "Response",
+    "TestApp",
+    # utils
+    "apply_types",
+    "context",
 )
diff --git a/faststream/asgi/__init__.py b/faststream/asgi/__init__.py
@@ -5,8 +5,8 @@
 
 __all__ = (
     "AsgiFastStream",
-    "make_ping_asgi",
-    "make_asyncapi_asgi",
     "AsgiResponse",
     "get",
+    "make_asyncapi_asgi",
+    "make_ping_asgi",
 )
diff --git a/faststream/asyncapi/__init__.py b/faststream/asyncapi/__init__.py
@@ -4,6 +4,6 @@
 from faststream.asyncapi.site import get_asyncapi_html
 
 __all__ = (
-    "get_asyncapi_html",
     "get_app_schema",
+    "get_asyncapi_html",
 )
diff --git a/faststream/asyncapi/schema/__init__.py b/faststream/asyncapi/schema/__init__.py
@@ -29,33 +29,33 @@
 __all__ = (
     # main
     "ASYNC_API_VERSION",
-    "Schema",
+    # channels
+    "Channel",
+    "ChannelBinding",
     "Components",
-    # info
-    "Info",
     "Contact",
     "ContactDict",
+    "CorrelationId",
+    "ExternalDocs",
+    "ExternalDocsDict",
+    # info
+    "Info",
     "License",
     "LicenseDict",
+    # messages
+    "Message",
+    # subscription
+    "Operation",
+    "OperationBinding",
+    "Reference",
+    "Schema",
+    # security
+    "SecuritySchemaComponent",
     # servers
     "Server",
-    # channels
-    "Channel",
+    # bindings
+    "ServerBinding",
     # utils
     "Tag",
     "TagDict",
-    "ExternalDocs",
-    "ExternalDocsDict",
-    "Reference",
-    # bindings
-    "ServerBinding",
-    "ChannelBinding",
-    "OperationBinding",
-    # messages
-    "Message",
-    "CorrelationId",
-    # security
-    "SecuritySchemaComponent",
-    # subscription
-    "Operation",
 )
diff --git a/faststream/broker/fastapi/_compat.py b/faststream/broker/fastapi/_compat.py
@@ -37,10 +37,10 @@
     )
 
 __all__ = (
+    "RequestValidationError",
     "create_response_field",
-    "solve_faststream_dependency",
     "raise_fastapi_validation_error",
-    "RequestValidationError",
+    "solve_faststream_dependency",
 )
 
 

diff --git a/faststream/broker/subscriber/call_item.py b/faststream/broker/subscriber/call_item.py
@@ -36,13 +36,13 @@ class HandlerItem(SetupAble, Generic[MsgType]):
     """A class representing handler overloaded item."""
 
     __slots__ = (
-        "handler",
-        "filter",
         "dependant",
         "dependencies",
-        "item_parser",
+        "filter",
+        "handler",
         "item_decoder",
         "item_middlewares",
+        "item_parser",
     )
 
     dependant: Optional[Any]

diff --git a/faststream/broker/subscriber/usecase.py b/faststream/broker/subscriber/usecase.py
@@ -53,11 +53,11 @@
 
 class _CallOptions:
     __slots__ = (
-        "filter",
-        "parser",
         "decoder",
-        "middlewares",
         "dependencies",
+        "filter",
+        "middlewares",
+        "parser",
     )
 
     def __init__(

diff --git a/faststream/broker/wrapper/call.py b/faststream/broker/wrapper/call.py
@@ -46,12 +46,12 @@ class HandlerCallWrapper(Generic[MsgType, P_HandlerParams, T_HandlerReturn]):
     _publishers: List["PublisherProto[MsgType]"]
 
     __slots__ = (
-        "mock",
-        "future",
-        "is_test",
-        "_wrapped_call",
         "_original_call",
         "_publishers",
+        "_wrapped_call",
+        "future",
+        "is_test",
+        "mock",
     )
 
     def __new__(

diff --git a/faststream/confluent/__init__.py b/faststream/confluent/__init__.py
@@ -9,11 +9,11 @@
 __all__ = (
     "KafkaBroker",
     "KafkaMessage",
-    "KafkaRouter",
-    "KafkaRoute",
     "KafkaPublisher",
     "KafkaResponse",
-    "TopicPartition",
-    "TestKafkaBroker",
+    "KafkaRoute",
+    "KafkaRouter",
     "TestApp",
+    "TestKafkaBroker",
+    "TopicPartition",
 )
diff --git a/faststream/confluent/annotations.py b/faststream/confluent/annotations.py
@@ -7,12 +7,12 @@
 from faststream.utils.context import Context
 
 __all__ = (
-    "Logger",
     "ContextRepo",
-    "NoCast",
-    "KafkaMessage",
     "KafkaBroker",
+    "KafkaMessage",
     "KafkaProducer",
+    "Logger",
+    "NoCast",
 )
 
 KafkaMessage = Annotated[KM, Context("message")]

diff --git a/faststream/confluent/fastapi/__init__.py b/faststream/confluent/fastapi/__init__.py
@@ -8,12 +8,12 @@
 
 __all__ = (
     "Context",
-    "Logger",
     "ContextRepo",
-    "KafkaRouter",
-    "KafkaMessage",
     "KafkaBroker",
+    "KafkaMessage",
     "KafkaProducer",
+    "KafkaRouter",
+    "Logger",
 )
 
 KafkaMessage = Annotated[KM, Context("message")]

diff --git a/faststream/confluent/schemas/partition.py b/faststream/confluent/schemas/partition.py
@@ -15,11 +15,11 @@ class _TopicKwargs(TypedDict):
 
 class TopicPartition:
     __slots__ = (
-        "topic",
-        "partition",
-        "offset",
-        "metadata",
         "leader_epoch",
+        "metadata",
+        "offset",
+        "partition",
+        "topic",
     )
 
     def __init__(

diff --git a/faststream/kafka/__init__.py b/faststream/kafka/__init__.py
@@ -10,11 +10,11 @@
 __all__ = (
     "KafkaBroker",
     "KafkaMessage",
-    "KafkaRouter",
-    "KafkaRoute",
-    "KafkaResponse",
     "KafkaPublisher",
-    "TestKafkaBroker",
+    "KafkaResponse",
+    "KafkaRoute",
+    "KafkaRouter",
     "TestApp",
+    "TestKafkaBroker",
     "TopicPartition",
 )
diff --git a/faststream/kafka/annotations.py b/faststream/kafka/annotations.py
@@ -8,12 +8,12 @@
 from faststream.utils.context import Context
 
 __all__ = (
-    "Logger",
     "ContextRepo",
-    "NoCast",
-    "KafkaMessage",
     "KafkaBroker",
+    "KafkaMessage",
     "KafkaProducer",
+    "Logger",
+    "NoCast",
 )
 
 Consumer = Annotated[AIOKafkaConsumer, Context("handler_.consumer")]

diff --git a/faststream/kafka/fastapi/__init__.py b/faststream/kafka/fastapi/__init__.py
@@ -8,12 +8,12 @@
 
 __all__ = (
     "Context",
-    "Logger",
     "ContextRepo",
-    "KafkaRouter",
-    "KafkaMessage",
     "KafkaBroker",
+    "KafkaMessage",
     "KafkaProducer",
+    "KafkaRouter",
+    "Logger",
 )
 
 KafkaMessage = Annotated[KM, Context("message")]

diff --git a/faststream/nats/__init__.py b/faststream/nats/__init__.py
@@ -22,29 +22,29 @@
 from faststream.testing.app import TestApp
 
 __all__ = (
-    "TestApp",
-    "NatsBroker",
-    "JStream",
-    "PullSub",
-    "KvWatch",
-    "ObjWatch",
-    "NatsRoute",
-    "NatsRouter",
-    "NatsPublisher",
-    "TestNatsBroker",
-    "NatsMessage",
-    "NatsResponse",
+    "AckPolicy",
     # Nats imports
     "ConsumerConfig",
     "DeliverPolicy",
-    "AckPolicy",
-    "ReplayPolicy",
     "DiscardPolicy",
-    "RetentionPolicy",
     "ExternalStream",
+    "JStream",
+    "KvWatch",
+    "NatsBroker",
+    "NatsMessage",
+    "NatsPublisher",
+    "NatsResponse",
+    "NatsRoute",
+    "NatsRouter",
+    "ObjWatch",
     "Placement",
+    "PullSub",
     "RePublish",
+    "ReplayPolicy",
+    "RetentionPolicy",
     "StorageType",
     "StreamConfig",
     "StreamSource",
+    "TestApp",
+    "TestNatsBroker",
 )
diff --git a/faststream/nats/annotations.py b/faststream/nats/annotations.py
@@ -12,13 +12,13 @@
 from faststream.utils.context import Context
 
 __all__ = (
-    "Logger",
-    "ContextRepo",
-    "NoCast",
-    "NatsMessage",
-    "NatsBroker",
     "Client",
+    "ContextRepo",
     "JsClient",
+    "Logger",
+    "NatsBroker",
+    "NatsMessage",
+    "NoCast",
     "ObjectStorage",
 )
 

diff --git a/faststream/nats/fastapi/__init__.py b/faststream/nats/fastapi/__init__.py
@@ -16,14 +16,14 @@
 NatsJsProducer = Annotated[NatsJSFastProducer, Context("broker._js_producer")]
 
 __all__ = (
+    "Client",
     "Context",
-    "Logger",
     "ContextRepo",
-    "NatsRouter",
+    "JsClient",
+    "Logger",
     "NatsBroker",
+    "NatsJsProducer",
     "NatsMessage",
-    "Client",
-    "JsClient",
     "NatsProducer",
-    "NatsJsProducer",
+    "NatsRouter",
 )
diff --git a/faststream/nats/helpers/__init__.py b/faststream/nats/helpers/__init__.py
@@ -4,6 +4,6 @@
 
 __all__ = (
     "KVBucketDeclarer",
-    "StreamBuilder",
     "OSBucketDeclarer",
+    "StreamBuilder",
 )
diff --git a/faststream/nats/schemas/__init__.py b/faststream/nats/schemas/__init__.py
@@ -5,7 +5,7 @@
 
 __all__ = (
     "JStream",
-    "PullSub",
     "KvWatch",
     "ObjWatch",
+    "PullSub",
 )
diff --git a/faststream/nats/schemas/js_stream.py b/faststream/nats/schemas/js_stream.py
@@ -23,10 +23,10 @@ class JStream(NameRequired):
     """A class to represent a JetStream stream."""
 
     __slots__ = (
-        "name",
         "config",
-        "subjects",
         "declare",
+        "name",
+        "subjects",
     )
 
     def __init__(