apply_types=False as default in get_broker

tests/prometheus/basic.py

@@ -18,7 +18,7 @@
 
 @pytest.mark.asyncio
 class LocalPrometheusTestcase(BaseTestcaseConfig):
-    def get_broker(self, **kwargs):
+    def get_broker(self, apply_types=False, **kwargs):
         raise NotImplementedError
 
     def get_middleware(self, **kwargs):
@@ -66,7 +66,7 @@ async def test_metrics(
         metrics_manager_mock = Mock()
         middleware._metrics_manager = metrics_manager_mock
 
-        broker = self.get_broker(middlewares=(middleware,))
+        broker = self.get_broker(apply_types=True, middlewares=(middleware,))
 
         args, kwargs = self.get_subscriber_params(queue)
 

tests/prometheus/confluent/test_confluent.py

@@ -15,8 +15,8 @@
 
 @pytest.mark.confluent
 class TestPrometheus(ConfluentTestcaseConfig, LocalPrometheusTestcase):
-    def get_broker(self, **kwargs):
-        return KafkaBroker(**kwargs)
+    def get_broker(self, apply_types=False, **kwargs):
+        return KafkaBroker(apply_types=apply_types, **kwargs)
 
     def get_middleware(self, **kwargs):
         return KafkaPrometheusMiddleware(**kwargs)
@@ -30,7 +30,7 @@ async def test_metrics_batch(
         metrics_manager_mock = Mock()
         middleware._metrics_manager = metrics_manager_mock
 
-        broker = self.get_broker(middlewares=(middleware,))
+        broker = self.get_broker(apply_types=True, middlewares=(middleware,))
 
         args, kwargs = self.get_subscriber_params(queue, batch=True)
         message = None

tests/prometheus/kafka/test_kafka.py

@@ -14,8 +14,8 @@
 
 @pytest.mark.kafka
 class TestPrometheus(LocalPrometheusTestcase):
-    def get_broker(self, **kwargs):
-        return KafkaBroker(**kwargs)
+    def get_broker(self, apply_types=False, **kwargs):
+        return KafkaBroker(apply_types=apply_types, **kwargs)
 
     def get_middleware(self, **kwargs):
         return KafkaPrometheusMiddleware(**kwargs)
@@ -29,7 +29,7 @@ async def test_metrics_batch(
         metrics_manager_mock = Mock()
         middleware._metrics_manager = metrics_manager_mock
 
-        broker = self.get_broker(middlewares=(middleware,))
+        broker = self.get_broker(apply_types=True, middlewares=(middleware,))
 
         args, kwargs = self.get_subscriber_params(queue, batch=True)
         message = None

tests/prometheus/nats/test_nats.py

@@ -19,8 +19,8 @@ def stream(queue):
 
 @pytest.mark.nats
 class TestPrometheus(LocalPrometheusTestcase):
-    def get_broker(self, **kwargs):
-        return NatsBroker(**kwargs)
+    def get_broker(self, apply_types=False, **kwargs):
+        return NatsBroker(apply_types=apply_types, **kwargs)
 
     def get_middleware(self, **kwargs):
         return NatsPrometheusMiddleware(**kwargs)
@@ -35,7 +35,7 @@ async def test_metrics_batch(
         metrics_manager_mock = Mock()
         middleware._metrics_manager = metrics_manager_mock
 
-        broker = self.get_broker(middlewares=(middleware,))
+        broker = self.get_broker(apply_types=True, middlewares=(middleware,))
 
         args, kwargs = self.get_subscriber_params(
             queue,

tests/prometheus/rabbit/test_rabbit.py

@@ -15,8 +15,8 @@ def exchange(queue):
 
 @pytest.mark.rabbit
 class TestPrometheus(LocalPrometheusTestcase):
-    def get_broker(self, **kwargs):
-        return RabbitBroker(**kwargs)
+    def get_broker(self, apply_types=False, **kwargs):
+        return RabbitBroker(apply_types=apply_types, **kwargs)
 
     def get_middleware(self, **kwargs):
         return RabbitPrometheusMiddleware(**kwargs)

tests/prometheus/redis/test_redis.py

@@ -14,8 +14,8 @@
 
 @pytest.mark.redis
 class TestPrometheus(LocalPrometheusTestcase):
-    def get_broker(self, **kwargs):
-        return RedisBroker(**kwargs)
+    def get_broker(self, apply_types=False, **kwargs):
+        return RedisBroker(apply_types=apply_types, **kwargs)
 
     def get_middleware(self, **kwargs):
         return RedisPrometheusMiddleware(**kwargs)
@@ -29,7 +29,7 @@ async def test_metrics_batch(
         metrics_manager_mock = Mock()
         middleware._metrics_manager = metrics_manager_mock
 
-        broker = self.get_broker(middlewares=(middleware,))
+        broker = self.get_broker(apply_types=True, middlewares=(middleware,))
 
         args, kwargs = self.get_subscriber_params(list=ListSub(queue, batch=True))