From a50e525a066f92fe5ed073fe597c5edb51eb5b2c Mon Sep 17 00:00:00 2001 From: didimelli <53627721+didimelli@users.noreply.github.com> Date: Tue, 13 Aug 2024 15:19:46 +0200 Subject: [PATCH] Remove loop argument from `aiokafka` driver (#641) * removed loop arg * restore double dict * re-add comma * tests --------- Co-authored-by: didimelli --- faust/transport/drivers/aiokafka.py | 1 - tests/unit/transport/drivers/test_aiokafka.py | 1 - 2 files changed, 2 deletions(-) diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py index 1c7c5fa13..e176fe3b4 100644 --- a/faust/transport/drivers/aiokafka.py +++ b/faust/transport/drivers/aiokafka.py @@ -1242,7 +1242,6 @@ def _new_producer( self, transactional_id: Optional[str] = None ) -> aiokafka.AIOKafkaProducer: return self._producer_type( - loop=self.loop, **{ **self._settings_default(), **self._settings_auth(), diff --git a/tests/unit/transport/drivers/test_aiokafka.py b/tests/unit/transport/drivers/test_aiokafka.py index 04d5d910f..35fe87ba4 100644 --- a/tests/unit/transport/drivers/test_aiokafka.py +++ b/tests/unit/transport/drivers/test_aiokafka.py @@ -1391,7 +1391,6 @@ def assert_new_producer( max_request_size=max_request_size, compression_type=compression_type, security_protocol=security_protocol, - loop=producer.loop, partitioner=producer.partitioner, transactional_id=None, api_version=api_version,