fix

airtai · Dec 3, 2024 · 794f39b · 794f39b
1 parent 26f0112
commit 794f39b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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):