    def iterations_in_epoch(self) -> int:
        """The number of consumed batches in the current epoch."""
        raise NotImplementedError
The number of consumed batches in the current epoch.
fairseq/data/iterators.py