Skip to content

Commit

Permalink
Adjust test for dask-expr
Browse files Browse the repository at this point in the history
  • Loading branch information
phofl committed Feb 8, 2024
1 parent 7e04ff7 commit 1a96a56
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions dask/dataframe/tests/test_dataframe.py
Original file line number Diff line number Diff line change
Expand Up @@ -1828,18 +1828,24 @@ def test_assign():

# divisions unknown won't work with pandas
with pytest.raises(ValueError):
ddf_unknown.assign(c=df.a + 1)
q = ddf_unknown.assign(c=df.a + 1)
if DASK_EXPR_ENABLED:
q.optimize()

# unsupported type
with pytest.raises(TypeError):
ddf.assign(c=list(range(9)))

# Fails when assigning known divisions to unknown divisions
with pytest.raises(ValueError):
ddf_unknown.assign(foo=ddf.a)
q = ddf_unknown.assign(foo=ddf.a)
if DASK_EXPR_ENABLED:
q.optimize()
# Fails when assigning unknown divisions to known divisions
with pytest.raises(ValueError):
ddf.assign(foo=ddf_unknown.a)
q = ddf.assign(foo=ddf_unknown.a)
if DASK_EXPR_ENABLED:
q.optimize()

df = pd.DataFrame({"A": [1, 2]})
df.assign(B=lambda df: df["A"], C=lambda df: df.A + df.B)
Expand Down

0 comments on commit 1a96a56

Please sign in to comment.