diff --git a/deepspeed/runtime/dataloader.py b/deepspeed/runtime/dataloader.py index acd21d9557fe..84b206e1eecd 100644 --- a/deepspeed/runtime/dataloader.py +++ b/deepspeed/runtime/dataloader.py @@ -68,10 +68,15 @@ def __init__(self, self.device_count = device_count self.batch_size = batch_size self.pin_memory = pin_memory - self.len = len(self.data_sampler) self.data = None self.dataloader_drop_last = dataloader_drop_last + if self.dataloader_drop_last: + self.len = len(self.data_sampler) // self.batch_size + else: + from math import ceil + self.len = ceil(len(self.data_sampler) / self.batch_size) + def __iter__(self): self._create_dataloader() return self