Skip to content
7 changes: 6 additions & 1 deletion deepspeed/runtime/dataloader.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down