游雁
2024-06-09 3eee773814c392e497557bbad501e0add4c8eca9
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)