Fixup pytest run w/o KAFKA_VERSION

dpkp · dpkp · commit bead3500780f · 2025-02-21T12:33:23.000-08:00
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py
@@ -276,6 +276,7 @@ def test_kafka_consumer_offsets_search_many_partitions(kafka_consumer, kafka_pro
     }
 
 
+@pytest.mark.skipif(not env_kafka_version(), reason="No KAFKA_VERSION set")
 @pytest.mark.skipif(env_kafka_version() >= (0, 10, 1), reason="Requires KAFKA_VERSION < 0.10.1")
 def test_kafka_consumer_offsets_for_time_old(kafka_consumer, topic):
     consumer = kafka_consumer

Original file line number	Diff line number	Diff line change
`@@ -276,6 +276,7 @@ def test_kafka_consumer_offsets_search_many_partitions(kafka_consumer, kafka_pro`
`276`	`276`	`}`
`277`	`277`
`278`	`278`
	`279`	`+@pytest.mark.skipif(not env_kafka_version(), reason="No KAFKA_VERSION set")`
`279`	`280`	`@pytest.mark.skipif(env_kafka_version() >= (0, 10, 1), reason="Requires KAFKA_VERSION < 0.10.1")`
`280`	`281`	`def test_kafka_consumer_offsets_for_time_old(kafka_consumer, topic):`
`281`	`282`	`consumer = kafka_consumer`