Skip to content

Commit 27b859c

Browse files
committed
feat: support pyspark 3 (via a databricks.koalas stub)
1 parent 6f5b111 commit 27b859c

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

eds_scikit/biology/viz/aggregate.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,8 +135,6 @@ def aggregate_concepts_set(
135135

136136
# Extract concept-set
137137
measurement_std_filtered = get_measurement_std(measurement_valid, src_to_std)
138-
if is_koalas(measurement_std_filtered):
139-
measurement_std_filtered.spark.cache()
140138
measurement_std_filtered = measurement_std_filtered.drop(
141139
columns="source_concept_id"
142140
)

tests/conftest.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,6 @@ def spark_session(pytestconfig, tmpdir_factory):
9999
f"jdbc:derby:;databaseName={temp_warehouse_dir}/metastore_db;create=true",
100100
)
101101
.set("spark.executor.cores", 1)
102-
.set("spark.driver.memory", "2g")
103102
)
104103

105104
session, _, _ = improve_performances(to_add_conf=list(conf.getAll()))

tests/test_biology.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,10 @@ def tmp_biology_dir(tmp_path_factory):
1414

1515
@pytest.fixture
1616
def data():
17-
return load_biology_data(seed=42)
17+
return load_biology_data(
18+
seed=42,
19+
mean_measurement=1000,
20+
)
1821

1922

2023
@pytest.fixture
@@ -73,6 +76,7 @@ def test_biology_summary(data, concepts_sets, module, tmp_biology_dir):
7376
limit_count=("AnaBio", 500),
7477
stats_only=True,
7578
save_folder_path=tmp_biology_dir,
79+
pd_limit_size=0,
7680
)
7781

7882

0 commit comments

Comments
 (0)