hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 02:21:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix a nightly dask on ray test (#18060)

Browse source
This commit is contained in:
SangBin Cho 2021-08-24 22:15:34 -07:00 • committed by GitHub
parent 08193b8e0a
commit 43da68e657
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
release/nightly_tests/dask_on_ray/dask_on_ray_sort.py
View file

@ -126,8 +126,8 @@ def trial(client,
# max_branch=float("inf")).compute(
# _ray_enable_progress_bar=True).head(10))
print(
df.set_index("a", shuffle="tasks",
max_branch=float("inf")).compute().head(10))
df.set_index("a", shuffle="tasks", max_branch=float("inf")).head(
10, npartitions=-1))
trial_end = time.time()
duration = trial_end - trial_start