We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 930ad03 commit 19d89b8Copy full SHA for 19d89b8
1 file changed
pubsublite/spark-connector/spark_streaming_test.py
@@ -176,6 +176,7 @@ def pyfile(source_file: str) -> str:
176
return "gs://" + blob.bucket.name + "/" + blob.name
177
178
179
+@pytest.mark.skip("PubSubLite is deprecated, and will be turned down March 18, 2026.")
180
def test_spark_streaming_to_pubsublite(
181
topic: Topic, dataproc_cluster: dataproc_v1.Cluster
182
) -> None:
@@ -229,6 +230,7 @@ def test_spark_streaming_to_pubsublite(
229
230
assert "Committed 1 messages for epochId" in output
231
232
233
234
def test_spark_streaming_from_pubsublite(
235
subscription: Subscription, dataproc_cluster: dataproc_v1.Cluster
236
0 commit comments