雾聪
2024-05-15 35d8c884a5a375361c416440431b9339c6e47585
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)