Skip to content

Commit c053cfd

Browse files
committed
PT: clear shuffler buffers in reset()
1 parent f069d06 commit c053cfd

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

returnn/torch/data/pipeline.py

+2
Original file line numberDiff line numberDiff line change
@@ -547,6 +547,8 @@ def set_seed(self, seed: int) -> ShufflingDataPipe:
547547

548548
def reset(self):
549549
"""resets the internal state of the data pipe"""
550+
self._buffer.clear()
551+
self._next_buffer.clear()
550552
if self._seed is None:
551553
self._seed = int(torch.empty((), dtype=torch.int32).random_().item())
552554
self._rng.seed(self._seed)

0 commit comments

Comments
 (0)