Remove loop argument from aiokafka driver (#641)

* removed loop arg * restore double dict * re-add comma * tests --------- Co-authored-by: didimelli <[email protected]>
faust-streaming · Aug 13, 2024 · a50e525 · a50e525
1 parent 232c4cf
commit a50e525
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git 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
@@ -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,