[Datasets] Fix API breakage in Datasets nightly test.

This commit is contained in:
Clark Zinzow 2021-10-07 15:07:19 -07:00 committed by GitHub
parent c3e3fc7637
commit ca731d7c86
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -85,7 +85,7 @@ def create_torch_iterator(split, batch_size, rank=None):
def create_dataset(filenames, repeat_times):
pipeline = ray.data.read_parquet(list(filenames))\
.repeat(times=repeat_times).random_shuffle()
.repeat(times=repeat_times).random_shuffle_each_window()
return pipeline