Skip to content

Commit

Permalink
Merge pull request #57 from martindurant/dask-fix
Browse files Browse the repository at this point in the history
Fix dask tests
  • Loading branch information
martindurant authored Jun 12, 2024
2 parents 2480e3d + d76f75a commit b1605bf
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions tests/test_dask.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
import pyarrow as pa
import pytest

import awkward_pandas # noqa
import awkward_pandas.dask # noqa

dd = pytest.importorskip("dask.dataframe")

Expand Down Expand Up @@ -36,7 +36,9 @@ def test_accessor():
def test_distributed():
distributed = pytest.importorskip("distributed")

with distributed.Client(n_workers=1, threads_per_worker=1):
with distributed.Client(
n_workers=1, threads_per_worker=1, preload=["awkward_pandas.dask"]
):
data = pd.arrays.ArrowExtensionArray(pa.array([[0], [0, 1]] * 2))
s = pd.Series(data)
df = pd.DataFrame({"s": s})
Expand Down

0 comments on commit b1605bf

Please sign in to comment.