pre-commit

tests/brokers/base/middlewares.py

@@ -111,7 +111,9 @@ async def handler(msg):
 
         assert [c.args[0] for c in mock.call_args_list] == ["outer", "middle", "inner"]
 
-    async def test_publisher_with_router_middleware_order(self, queue: str, mock: Mock, raw_broker):
+    async def test_publisher_with_router_middleware_order(
+        self, queue: str, mock: Mock, raw_broker
+    ):
         class InnerMiddleware(BaseMiddleware):
             async def publish_scope(self, call_next, msg, *args, **kwargs):
                 mock.publish_inner()
@@ -196,7 +198,9 @@ async def handler(msg):
 
         assert [c.args[0] for c in mock.call_args_list] == ["outer", "middle", "inner"]
 
-    async def test_consume_with_middleware_order(self, queue: str, mock: Mock, raw_broker):
+    async def test_consume_with_middleware_order(
+        self, queue: str, mock: Mock, raw_broker
+    ):
         class InnerMiddleware(BaseMiddleware):
             async def consume_scope(self, call_next, msg):
                 mock.consume_inner()

tests/brokers/confluent/test_middlewares.py

@@ -19,6 +19,7 @@ class TestMiddlewares(ConfluentTestcaseConfig, MiddlewareTestcase):
 class TestExceptionMiddlewares(ConfluentTestcaseConfig, ExceptionMiddlewareTestcase):
     broker_class = KafkaBroker
 
+
 @pytest.mark.confluent
 class TestMiddlewaresOrder(MiddlewaresOrderTestcase):
     broker_class = KafkaBroker

tests/brokers/kafka/test_middlewares.py

@@ -17,6 +17,7 @@ class TestMiddlewares(MiddlewareTestcase):
 class TestExceptionMiddlewares(ExceptionMiddlewareTestcase):
     broker_class = KafkaBroker
 
+
 @pytest.mark.kafka
 class TestMiddlewaresOrder(MiddlewaresOrderTestcase):
     broker_class = KafkaBroker

tests/brokers/rabbit/test_middlewares.py

@@ -17,6 +17,7 @@ class TestMiddlewares(MiddlewareTestcase):
 class TestExceptionMiddlewares(ExceptionMiddlewareTestcase):
     broker_class = RabbitBroker
 
+
 @pytest.mark.rabbit
 class TestMiddlewaresOrder(MiddlewaresOrderTestcase):
     broker_class = RabbitBroker

tests/brokers/redis/test_middlewares.py

@@ -17,6 +17,7 @@ class TestMiddlewares(MiddlewareTestcase):
 class TestExceptionMiddlewares(ExceptionMiddlewareTestcase):
     broker_class = RedisBroker
 
+
 @pytest.mark.redis
 class TestMiddlewaresOrder(MiddlewaresOrderTestcase):
     broker_class = RedisBroker