From 794f39b306cfbac4f149d51bbe13d8d21c3e61d5 Mon Sep 17 00:00:00 2001 From: Daniil Dumchenko Date: Tue, 3 Dec 2024 23:40:03 +0700 Subject: [PATCH] fix --- tests/brokers/confluent/test_consume.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/brokers/confluent/test_consume.py b/tests/brokers/confluent/test_consume.py index 49a20a867d..7dff51fbcb 100644 --- a/tests/brokers/confluent/test_consume.py +++ b/tests/brokers/confluent/test_consume.py @@ -331,7 +331,7 @@ async def test_concurrent_consume(self, queue: str, mock: MagicMock): consume_broker = self.get_broker() - args, kwargs = self.get_subscriber_params(queue, group_id="test", max_workers=2) + args, kwargs = self.get_subscriber_params(queue, max_workers=2) @consume_broker.subscriber(*args, **kwargs) async def handler(msg):