We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3403ce7 commit ba1d959Copy full SHA for ba1d959
1 file changed
tests/integration/test_session.py
@@ -372,14 +372,8 @@ def test_create_spark_session_with_session_template_and_user_provided_dataproc_c
372
assert DataprocSparkSession._active_s8s_session_uuid is None
373
374
375
-@pytest.mark.skip(
376
- reason="Skipping PyPI package installation test since it's not supported yet"
377
-)
378
def test_add_artifacts_pypi_package():
379
- """Test adding PyPI packages as artifacts to a Spark session.
380
-
381
- Note: Skipped in CI due to infrastructure issues with PyPI package installation.
382
- """
+ """Test adding PyPI packages as artifacts to a Spark session."""
383
connect_session = DataprocSparkSession.builder.getOrCreate()
384
from pyspark.sql.connect.functions import udf, sum
385
from pyspark.sql.types import IntegerType
0 commit comments