Skip to content

Commit

Permalink
linting fix
Browse files Browse the repository at this point in the history
  • Loading branch information
snarayan21 committed Oct 26, 2023
1 parent 8e904be commit e06ebc8
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions streaming/base/dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -749,12 +749,12 @@ def state_dict(self, num_samples: int, from_beginning: bool) -> Dict[str, Any]:
else:
sample_in_epoch = offset + num_samples

# If `self.initial_physical_nodes` is None, we are running for the first time, so we set
# If `self.initial_physical_nodes` is None, we are running for the first time, so we set
# initial_physical_nodes to the current number of physical nodes. Otherwise, we persist
# initial_physical_nodes as the value loaded and set from the resumption state.
initial_physical_nodes = world.num_nodes if self.initial_physical_nodes is None \
else self.initial_physical_nodes

return {
'epoch': epoch,
'sample_in_epoch': sample_in_epoch,
Expand Down

0 comments on commit e06ebc8

Please sign in to comment.