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)