Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
goodwanghan authored Dec 1, 2023
1 parent 9e8995b commit 18c421b
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions tests/fugue_polars/test_transform.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ def tr3(dfs: Iterable[pl.DataFrame]) -> Iterator[pl.DataFrame]:
assert fdf.as_array() == []


def test_polars_on_engines(spark_session, fugue_dask_client, fugue_ray_session):
def test_polars_on_engines(spark_session, dask_session, ray_session):
def tr1(df: pl.DataFrame) -> pl.DataFrame:
tdf = df.with_columns(pl.lit(1, pl.Int32()).alias("c"))
return tdf
Expand All @@ -92,6 +92,6 @@ def test(engine):

test(spark_session)

test(fugue_dask_client)
test(dask_session)

test(fugue_ray_session)
test(ray_session)

0 comments on commit 18c421b

Please sign in to comment.