def METHOD_NAME(self, task: Task):
    record_count = task.shard.end - task.shard.start
    batch_count = math.ceil(record_count / self._batch_size)
    self._completed_step += batch_count
    self._latest_task_end_time = int(time.time())