You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ja...@apache.org on 2026/05/02 09:53:52 UTC

(airflow) branch main updated: Enable PT007 rule to apache.kafka Provider test (#66147)

This is an automated email from the ASF dual-hosted git repository.

jason810496 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 1738252d21a Enable PT007 rule to apache.kafka Provider test (#66147)
1738252d21a is described below

commit 1738252d21ad65333ec884579eec910acc5472cc
Author: Colten <70...@users.noreply.github.com>
AuthorDate: Sat May 2 17:53:45 2026 +0800

    Enable PT007 rule to apache.kafka Provider test (#66147)
---
 .../apache/kafka/tests/unit/apache/kafka/operators/test_consume.py  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/providers/apache/kafka/tests/unit/apache/kafka/operators/test_consume.py b/providers/apache/kafka/tests/unit/apache/kafka/operators/test_consume.py
index e13258e19a0..e883825b2ff 100644
--- a/providers/apache/kafka/tests/unit/apache/kafka/operators/test_consume.py
+++ b/providers/apache/kafka/tests/unit/apache/kafka/operators/test_consume.py
@@ -128,9 +128,9 @@ class TestConsumeFromTopic:
     @pytest.mark.parametrize(
         ("max_messages", "expected_consumed_messages"),
         [
-            [None, 1001],  # Consume all messages
-            [100, 1000],  # max_messages < max_batch_size -> max_messages is set to default max_batch_size
-            [2000, 1001],  # max_messages > max_batch_size
+            (None, 1001),  # Consume all messages
+            (100, 1000),  # max_messages < max_batch_size -> max_messages is set to default max_batch_size
+            (2000, 1001),  # max_messages > max_batch_size
         ],
     )
     def test_operator_consume(self, max_messages, expected_consumed_messages):