Bump completed progress on load with checkpoints saved on_train_batch_end #20379

lantiga · 2024-10-31T15:18:18Z

What does this PR do?

The following code

import torch
from torch.utils.data import DataLoader, Dataset
 
import lightning as L
from lightning.pytorch.callbacks import ModelCheckpoint

 
class RandomDataset(Dataset):
   def __init__(self, size, length):
       self.len = length
       self.data = torch.randn(length, size)
 
   def __getitem__(self, index):
       return self.data[index]
 
   def __len__(self):
       return self.len
 
 
class BoringModel(L.LightningModule):
   def __init__(self):
       super().__init__()
       self.layer = torch.nn.Linear(32, 2)
 
   def forward(self, x):
       return self.layer(x)
 
   def training_step(self, batch, batch_idx):
       loss = self(batch).sum()
       return {"loss": loss}
 
   def configure_optimizers(self):
       return torch.optim.SGD(self.layer.parameters(), lr=0.1)

 
train_data = DataLoader(RandomDataset(32, 24), batch_size=2)
 
model = BoringModel()

trainer = L.Trainer(
   default_root_dir=".",
   max_steps=10,
   enable_model_summary=False,
   accelerator="cpu",
   callbacks=ModelCheckpoint(dirpath="./lightning_logs/checkpoints", save_last=True, save_top_k=-1, every_n_train_steps=10),
)
trainer.fit(model, train_data)

trainer = L.Trainer(
   default_root_dir=".",
   max_steps=20,
   enable_model_summary=False,
   accelerator="cpu",
   callbacks=ModelCheckpoint(dirpath="./lightning_logs/checkpoints", save_last=True, save_top_k=-1, every_n_train_steps=10),
)
trainer.fit(model, train_data, ckpt_path='last')

will produce skewed progress information in the checkpoints, compared to the case where there is no restart.

This is due to the fact that when ModelCheckpoint is triggered on on_train_batch_end, it won't see batch_progress.total.completed updated to the latest batch that was processed, because progress is updated right after the hook is called.

However, upon restart, there won't be any opportunity to register the actual completion of the batch, causing a skew that is proportional to the number of restarts. This impacts the time at which validation is called, which itself becomes dependent from restarts.

This PR addresses this issue by reconciling progress upon restart.

Before submitting

Was this discussed/agreed via a GitHub issue? (not for typos and docs)
Did you read the contributor guideline, Pull Request section?
Did you make sure your PR does only one thing, instead of bundling different changes together?
Did you make sure to update the documentation with your changes? (if necessary)
Did you write any new necessary tests? (not for typos and docs)
Did you verify new and existing tests pass locally with your changes?
Did you list all the breaking changes introduced by this pull request?
Did you update the CHANGELOG? (not for typos, docs, test updates, or minor internal changes/refactors)

PR review

Anyone in the community is welcome to review the PR.
Before you start reviewing, make sure you have read the review guidelines. In short, see the following bullet-list:

Reviewer checklist

Is this pull request ready for review? (if not, please submit in draft mode)
Check that all items from Before submitting are resolved
Make sure the title is self-explanatory and the description concisely explains the PR
Add labels and milestones (and optionally projects) to the PR so it can be classified

📚 Documentation preview 📚: https://pytorch-lightning--20379.org.readthedocs.build/en/20379/

github-actions · 2024-10-31T15:18:45Z

⛈️ Required checks status: Has failure 🔴

Warning
This job will need to be re-run to merge your PR. If you do not have write access to the repository, you can ask Lightning-AI/lai-frameworks to re-run it. If you push a new commit, all of CI will re-trigger.

Groups summary

🔴 pytorch_lightning: Tests workflow

Check ID	Status
pl-cpu (macOS-13, lightning, 3.9, 2.1, oldest)	failure	❌
pl-cpu (macOS-14, lightning, 3.10, 2.1)	failure	❌
pl-cpu (macOS-14, lightning, 3.11, 2.2)	failure	❌
pl-cpu (macOS-14, lightning, 3.11, 2.3)	failure	❌
pl-cpu (macOS-14, lightning, 3.12, 2.4)	failure	❌
pl-cpu (ubuntu-20.04, lightning, 3.9, 2.1, oldest)	failure	❌
pl-cpu (ubuntu-20.04, lightning, 3.10, 2.1)	failure	❌
pl-cpu (ubuntu-20.04, lightning, 3.11, 2.2)	failure	❌
pl-cpu (ubuntu-20.04, lightning, 3.11, 2.3)	failure	❌
pl-cpu (ubuntu-20.04, lightning, 3.12, 2.4)	failure	❌
pl-cpu (windows-2022, lightning, 3.9, 2.1, oldest)	failure	❌
pl-cpu (windows-2022, lightning, 3.10, 2.1)	failure	❌
pl-cpu (windows-2022, lightning, 3.11, 2.2)	failure	❌
pl-cpu (windows-2022, lightning, 3.11, 2.3)	failure	❌
pl-cpu (windows-2022, lightning, 3.12, 2.4)	failure	❌
pl-cpu (macOS-14, pytorch, 3.9, 2.1)	failure	❌
pl-cpu (ubuntu-20.04, pytorch, 3.9, 2.1)	failure	❌
pl-cpu (windows-2022, pytorch, 3.9, 2.1)	failure	❌
pl-cpu (macOS-12, pytorch, 3.10, 2.1)	no_status	❓
pl-cpu (ubuntu-22.04, pytorch, 3.10, 2.1)	failure	❌
pl-cpu (windows-2022, pytorch, 3.10, 2.1)	failure	❌

These checks are required after the changes to src/lightning/pytorch/loops/evaluation_loop.py, src/lightning/pytorch/loops/fit_loop.py, src/lightning/pytorch/loops/loop.py, src/lightning/pytorch/loops/progress.py, src/lightning/pytorch/loops/training_epoch_loop.py, tests/tests_pytorch/loops/test_loops.py.

🟢 pytorch_lightning: Azure GPU

Check ID	Status
pytorch-lightning (GPUs) (testing Lightning \| latest)	success	✅
pytorch-lightning (GPUs) (testing PyTorch \| latest)	success	✅

These checks are required after the changes to src/lightning/pytorch/loops/evaluation_loop.py, src/lightning/pytorch/loops/fit_loop.py, src/lightning/pytorch/loops/loop.py, src/lightning/pytorch/loops/progress.py, src/lightning/pytorch/loops/training_epoch_loop.py, tests/tests_pytorch/loops/test_loops.py.

🟢 pytorch_lightning: Benchmarks

Check ID	Status
lightning.Benchmarks	success	✅

These checks are required after the changes to src/lightning/pytorch/loops/evaluation_loop.py, src/lightning/pytorch/loops/fit_loop.py, src/lightning/pytorch/loops/loop.py, src/lightning/pytorch/loops/progress.py, src/lightning/pytorch/loops/training_epoch_loop.py.

🟢 pytorch_lightning: Docs

Check ID	Status
docs-make (pytorch, doctest)	success	✅
docs-make (pytorch, html)	success	✅

These checks are required after the changes to src/lightning/pytorch/loops/evaluation_loop.py, src/lightning/pytorch/loops/fit_loop.py, src/lightning/pytorch/loops/loop.py, src/lightning/pytorch/loops/progress.py, src/lightning/pytorch/loops/training_epoch_loop.py.

🔴 mypy

Check ID	Status
mypy	failure	❌

These checks are required after the changes to src/lightning/pytorch/loops/evaluation_loop.py, src/lightning/pytorch/loops/fit_loop.py, src/lightning/pytorch/loops/loop.py, src/lightning/pytorch/loops/progress.py, src/lightning/pytorch/loops/training_epoch_loop.py.

🟡 install

Check ID	Status
install-pkg (ubuntu-22.04, fabric, 3.9)	success	✅
install-pkg (ubuntu-22.04, fabric, 3.11)	success	✅
install-pkg (ubuntu-22.04, pytorch, 3.9)	success	✅
install-pkg (ubuntu-22.04, pytorch, 3.11)	success	✅
install-pkg (ubuntu-22.04, lightning, 3.9)	success	✅
install-pkg (ubuntu-22.04, lightning, 3.11)	success	✅
install-pkg (ubuntu-22.04, notset, 3.9)	success	✅
install-pkg (ubuntu-22.04, notset, 3.11)	success	✅
install-pkg (macOS-12, fabric, 3.9)	no_status	❓
install-pkg (macOS-12, fabric, 3.11)	no_status	❓
install-pkg (macOS-12, pytorch, 3.9)	no_status	❓
install-pkg (macOS-12, pytorch, 3.11)	no_status	❓
install-pkg (macOS-12, lightning, 3.9)	no_status	❓
install-pkg (macOS-12, lightning, 3.11)	no_status	❓
install-pkg (macOS-12, notset, 3.9)	no_status	❓
install-pkg (macOS-12, notset, 3.11)	no_status	❓
install-pkg (windows-2022, fabric, 3.9)	success	✅
install-pkg (windows-2022, fabric, 3.11)	success	✅
install-pkg (windows-2022, pytorch, 3.9)	success	✅
install-pkg (windows-2022, pytorch, 3.11)	success	✅
install-pkg (windows-2022, lightning, 3.9)	success	✅
install-pkg (windows-2022, lightning, 3.11)	success	✅
install-pkg (windows-2022, notset, 3.9)	success	✅
install-pkg (windows-2022, notset, 3.11)	success	✅

These checks are required after the changes to src/lightning/pytorch/loops/evaluation_loop.py, src/lightning/pytorch/loops/fit_loop.py, src/lightning/pytorch/loops/loop.py, src/lightning/pytorch/loops/progress.py, src/lightning/pytorch/loops/training_epoch_loop.py.

Thank you for your contribution! 💜

Note
This comment is automatically generated and updates for 60 minutes every 180 seconds. If you have any other questions, contact carmocca for help.

lantiga requested review from Borda, tchaton and justusschock as code owners October 31, 2024 15:18

github-actions bot added the pl Generic label for PyTorch Lightning package label Oct 31, 2024

lantiga added 7 commits November 5, 2024 18:19

Fix checkpoint progress for fit loop and batch loop

ac73938

Check loss parity

2d5576d

Rename test

0750b2e

Fix validation loop handling on restart

cbb9fb5

Fix loop reset test

7d0b5a1

Avoid skipping to val end if saved mid validation

e8bd2d7

Fix type checks in compare state dicts

0012dcb

lantiga force-pushed the luca/restart-batch-fix branch from 5e313ee to 0012dcb Compare November 6, 2024 13:39

lantiga added 3 commits November 7, 2024 18:44

Fix edge cases and start from last with and without val

e64c200

Clean up

59e41de

Formatting

c3469be

lantiga force-pushed the luca/restart-batch-fix branch from d303d27 to c3469be Compare November 8, 2024 10:39

sichu2023 mentioned this pull request Nov 8, 2024

Update NeMo/Megatron NVIDIA/bionemo-framework#302

Open

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Bump completed progress on load with checkpoints saved on_train_batch_end #20379

Bump completed progress on load with checkpoints saved on_train_batch_end #20379

lantiga commented Oct 31, 2024 •

edited by github-actions bot

Loading

github-actions bot commented Oct 31, 2024 •

edited

Loading

Bump completed progress on load with checkpoints saved on_train_batch_end #20379

Are you sure you want to change the base?

Bump completed progress on load with checkpoints saved on_train_batch_end #20379

Conversation

lantiga commented Oct 31, 2024 • edited by github-actions bot Loading

What does this PR do?

PR review

github-actions bot commented Oct 31, 2024 • edited Loading

⛈️ Required checks status: Has failure 🔴

Groups summary

lantiga commented Oct 31, 2024 •

edited by github-actions bot

Loading

github-actions bot commented Oct 31, 2024 •

edited

Loading