File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
pubsublite/spark-connector Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -176,6 +176,7 @@ def pyfile(source_file: str) -> str:
176176 return "gs://" + blob .bucket .name + "/" + blob .name
177177
178178
179+ @pytest .mark .skip ("PubSubLite is deprecated, and will be turned down March 18, 2026." )
179180def test_spark_streaming_to_pubsublite (
180181 topic : Topic , dataproc_cluster : dataproc_v1 .Cluster
181182) -> None :
@@ -229,6 +230,7 @@ def test_spark_streaming_to_pubsublite(
229230 assert "Committed 1 messages for epochId" in output
230231
231232
233+ @pytest .mark .skip ("PubSubLite is deprecated, and will be turned down March 18, 2026." )
232234def test_spark_streaming_from_pubsublite (
233235 subscription : Subscription , dataproc_cluster : dataproc_v1 .Cluster
234236) -> None :
You can’t perform that action at this time.
0 commit comments