游雁
2024-04-30 1ac23a0cc12d53f76e016df5339bbf4d3fdfde6b
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)