Simplify skipIf condition

zhengruifeng · zhengruifeng · commit 89390006c344 · 2026-04-09T04:34:27.000Z
Co-authored-by: Isaac
diff --git a/python/pyspark/sql/tests/streaming/test_streaming_kafka_rtm.py b/python/pyspark/sql/tests/streaming/test_streaming_kafka_rtm.py
@@ -113,7 +113,7 @@ def _is_docker_available():
 
 
 @unittest.skipIf(
-    not (have_testcontainers and have_kafka),
+    not have_testcontainers or not have_kafka,
     "Kafka test dependencies not available (testcontainers, kafka-python)",
 )
 class StreamingKafkaTests(StreamingKafkaTestsMixin, ReusedSQLTestCase):

Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,7 @@ def _is_docker_available():`
`113`	`113`
`114`	`114`
`115`	`115`	`@unittest.skipIf(`
`116`		`- not (have_testcontainers and have_kafka),`
	`116`	`+ not have_testcontainers or not have_kafka,`
`117`	`117`	`"Kafka test dependencies not available (testcontainers, kafka-python)",`
`118`	`118`	`)`
`119`	`119`	`class StreamingKafkaTests(StreamingKafkaTestsMixin, ReusedSQLTestCase):`