Skip to content

Commit 7caac98

Browse files
eakmanrqclaude
andcommitted
Run pyspark tests without xdist to prevent fork OOM
xdist workers use fork() to spawn Spark JVM subprocesses, which temporarily doubles virtual memory and triggers OOM on CI runners. Exclude pyspark-marked tests from the parallel run and execute them sequentially in a dedicated pass. Also add the missing @pytest.mark.pyspark marker to test_pyspark_python_model. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> Signed-off-by: eakmanrq <6326532+eakmanrq@users.noreply.github.com>
1 parent 4d57ea7 commit 7caac98

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

Makefile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ slow-test:
130130
pytest -n auto -m "(fast or slow) and not cicdonly" && pytest -m "isolated" && pytest -m "registry_isolation" && pytest -m "dialect_isolated"
131131

132132
cicd-test:
133-
pytest -n auto -m "fast or slow" --junitxml=test-results/junit-cicd.xml && pytest -m "isolated" && pytest -m "registry_isolation" && pytest -m "dialect_isolated"
133+
pytest -n auto -m "(fast or slow) and not pyspark" --junitxml=test-results/junit-cicd.xml && pytest -m "pyspark" && pytest -m "isolated" && pytest -m "registry_isolation" && pytest -m "dialect_isolated"
134134

135135
core-fast-test:
136136
pytest -n auto -m "fast and not web and not github and not dbt and not jupyter"

tests/core/test_test.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1718,6 +1718,7 @@ def test_generate_input_data_using_sql(mocker: MockerFixture, tmp_path: Path) ->
17181718
)
17191719

17201720

1721+
@pytest.mark.pyspark
17211722
def test_pyspark_python_model(tmp_path: Path) -> None:
17221723
spark_connection_config = SparkConnectionConfig(
17231724
config={

0 commit comments

Comments
 (0)