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):