MCPcopy
hub / github.com/pandas-dev/pandas / test_dask

Function test_dask

pandas/tests/test_downstream.py:32–45  ·  view source on GitHub ↗
(df)

Source from the content-addressed store, hash-verified

30
31
32def test_dask(df):
33 # dask sets "compute.use_numexpr" to False, so catch the current value
34 # and ensure to reset it afterwards to avoid impacting other tests
35 olduse = pd.get_option("compute.use_numexpr")
36
37 try:
38 pytest.importorskip("toolz")
39 dd = pytest.importorskip("dask.dataframe")
40
41 ddf = dd.from_pandas(df, npartitions=3)
42 assert ddf.A is not None
43 assert ddf.compute() is not None
44 finally:
45 pd.set_option("compute.use_numexpr", olduse)
46
47
48# TODO(CoW) see https://github.com/pandas-dev/pandas/pull/51082

Callers

nothing calls this directly

Calls 1

computeMethod · 0.45

Tested by

no test coverage detected