szsteven008
2024-05-28 bd9e63063f7cf6cd5f61d8633472fdd4b63484be
funasr/datasets/large_datasets/datapipes/map.py
@@ -7,14 +7,12 @@
class MapperIterDataPipe(IterableDataset):
    def __init__(self,
                 datapipe,
                 fn=default_fn):
    def __init__(self, datapipe, fn=default_fn):
        self.datapipe = datapipe
        self.fn = fn
    def set_epoch(self, epoch):
        self.epoch = epoch
        self.datapipe.set_epoch(epoch)
    def __iter__(self):
        assert callable(self.fn)