Skip to content

Commit

Permalink
more
Browse files Browse the repository at this point in the history
  • Loading branch information
douglasdavis committed Jul 6, 2023
1 parent e153158 commit ee2c45c
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions tests/test_optimize.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
from __future__ import annotations

import awkward as ak
import dask

import dask_awkward as dak
Expand All @@ -11,5 +12,11 @@ def test_multiple_computes(pq_points_dir) -> None:
# from_parquet so we get two unique collections.
ds2 = dak.from_parquet(pq_points_dir, columns=["points"])

lists = [[[1, 2, 3], [4, 5]], [[], [0, 0, 0]]]
ds3 = dak.from_lists([[[1, 2, 3], [4, 5]], [[], [0, 0, 0]]])

assert ds1.name != ds2.name
assert dask.compute(ds1.points.x, ds2.points.y)
assert dask.compute(ds1.points)
things = dask.compute(ds1.points, ds2.points.x, ds2.points.y, ds1.points.y, ds3)
assert things[-1].tolist() == ak.Array(lists[0] + lists[1]).tolist()

0 comments on commit ee2c45c

Please sign in to comment.