Fixes after pre-commit

Author: Вадим Козыревский

docker-compose-dev.yml

@@ -41,4 +41,4 @@ services:
       KAFKA_LOG_DIRS: '/tmp/kraft-combined-logs'
     volumes:
       - ./scripts/update_run.sh:/tmp/update_run.sh
-    command: "bash -c 'if [ ! -f /tmp/update_run.sh ]; then echo \"ERROR: Did you forget the update_run.sh file that came with this docker-compose.yml file?\" && exit 1 ; else /tmp/update_run.sh && /etc/confluent/docker/run ; fi'"
+    command: "bash -c 'if [ ! -f /tmp/update_run.sh ]; then echo \"ERROR: Did you forget the update_run.sh file that came with this docker-compose.yml file?\" && exit 1 ; else /tmp/update_run.sh && /etc/confluent/docker/run ; fi'"

examples/kafka_event_consuming.py

@@ -109,11 +109,11 @@
 
 
 async def empty_message_decoder(
-        msg: kafka.KafkaMessage,
-        original_decoder: typing.Callable[
-            [kafka.KafkaMessage],
-            typing.Awaitable[types.DecodedMessage],
-        ],
+    msg: kafka.KafkaMessage,
+    original_decoder: typing.Callable[
+        [kafka.KafkaMessage],
+        typing.Awaitable[types.DecodedMessage],
+    ],
 ) -> types.DecodedMessage | None:
     """
     Decode a kafka message and return it if it is not empty.
@@ -158,11 +158,11 @@ def mediator_factory() -> cqrs.EventMediator:
     decoder=empty_message_decoder,
 )
 async def hello_world_event_handler(
-        body: cqrs.NotificationEvent[HelloWorldPayload]
-              | deserializers.DeserializeJsonError
-              | None,
-        msg: kafka.KafkaMessage,
-        mediator: cqrs.EventMediator = faststream.Depends(mediator_factory),
+    body: cqrs.NotificationEvent[HelloWorldPayload]
+    | deserializers.DeserializeJsonError
+    | None,
+    msg: kafka.KafkaMessage,
+    mediator: cqrs.EventMediator = faststream.Depends(mediator_factory),
 ):
     if not isinstance(body, deserializers.DeserializeJsonError) and body is not None:
         await mediator.send(body)

pyproject.toml

@@ -53,15 +53,15 @@ examples = [
   "faststream[kafka]==0.5.28",
   "faker>=37.12.0"
 ]
-rabbit = [
-  "aio-pika==9.3.0",
-]
 kafka = [
   "aiokafka==0.10.0",
   # for SchemaRegistry
   "confluent-kafka==2.6.0"
 ]
 protobuf = ["protobuf==4.25.5"]
+rabbit = [
+  "aio-pika==9.3.0"
+]
 
 [project.urls]
 Documentation = "https://vadikko2.github.io/python-cqrs-mkdocs/"