Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Stateful DL] Add out of order implementation #1423

Merged

Conversation

michael-diggin
Copy link
Contributor

@michael-diggin michael-diggin commented Jan 20, 2025

Fixes #1414

Changes

The tests I've added were the exact same ones from the main PyTorch repo, so the functionality of the flag is the exact same. There was a few changes required to be compatible with the few slight differences of the _StatefulMultiProcessingDataLoaderIter.

I have also tested some simple cases of stopping/resuming both an index and iterable ds and it seems to work correctly (the same types that are used in the new test cases). I haven't added extra tests for that into this PR just to keep the size manageable, but would add them in a follow up PR as well as checking extra edge cases.

@facebook-github-bot
Copy link
Contributor

Hi @michael-diggin!

Thank you for your pull request and welcome to our community.

Action Required

In order to merge any pull request (code, docs, etc.), we require contributors to sign our Contributor License Agreement, and we don't seem to have one on file for you.

Process

In order for us to review and merge your suggested changes, please sign at https://code.facebook.com/cla. If you are contributing on behalf of someone else (eg your employer), the individual CLA may not be sufficient and your employer may need to sign the corporate CLA.

Once the CLA is signed, our tooling will perform checks and validations. Afterwards, the pull request will be tagged with CLA signed. The tagging process may take up to 1 hour after signing. Please give it that time before contacting us about it.

If you have received this in error or have any questions, please contact us at [email protected]. Thanks!

@facebook-github-bot
Copy link
Contributor

Thank you for signing our Contributor License Agreement. We can now accept your code for this (and any) Meta Open Source project. Thanks!

@facebook-github-bot facebook-github-bot added the CLA Signed This label is managed by the Facebook bot. Authors need to sign the CLA before a PR can be reviewed. label Jan 20, 2025
@andrewkho
Copy link
Contributor

@michael-diggin thanks for making this PR! Can add a warning on the first call to _StatefulMultiProcessingIter.state_dict() if in_order=False please?

Copy link

pytorch-bot bot commented Jan 22, 2025

🔗 Helpful Links

🧪 See artifacts and rendered test results at hud.pytorch.org/pr/pytorch/data/1423

Note: Links to docs will display an error until the docs builds have been completed.

✅ You can merge normally! (1 Unrelated Failure)

As of commit 9a43220 with merge base d6232f1 (image):

FLAKY - The following job failed but was likely due to flakiness present on trunk:

This comment was automatically generated by Dr. CI and updates every 15 minutes.

@michael-diggin
Copy link
Contributor Author

@michael-diggin thanks for making this PR! Can add a warning on the first call to _StatefulMultiProcessingIter.state_dict() if in_order=False please?

No problem, done. I've gone with having it log on every call, but happy to add some state to track if it's the first call and to check that/only log once.

@michael-diggin
Copy link
Contributor Author

michael-diggin commented Jan 27, 2025

Hi @andrewkho, just bumping this - I’ve made the changes above. It would be great to get another review if you get a chance this week!

@andrewkho
Copy link
Contributor

sorry for the delay @michael-diggin , let's just roll it out since we're going to cut release branch soon. I'll start the CI and once it's green we can merge. Thank you again!

@michael-diggin
Copy link
Contributor Author

sorry for the delay @michael-diggin , let's just roll it out since we're going to cut release branch soon. I'll start the CI and once it's green we can merge. Thank you again!

Sounds good, thanks!
I’ll have a follow up PR soon-ish to add tests for out of order and state dicts/resuming from a checkpoint but that shouldn’t hold up cutting a release.

@michael-diggin
Copy link
Contributor Author

I think there might be an issue with the worker that is running one of the tests - it hasn't made progress in about 90 mins
https://github.com/pytorch/data/actions/runs/12954834427/job/36239624635?pr=1423

@michael-diggin
Copy link
Contributor Author

I think there might be an issue with the worker that is running one of the tests - it hasn't made progress in about 90 mins https://github.com/pytorch/data/actions/runs/12954834427/job/36239624635?pr=1423

FYI @andrewkho, I would think it just needs the CI to be rerun?

@andrewkho
Copy link
Contributor

@michael-diggin I think we're good to land, I'll go ahead and merge, thanks again for the contribution!

@andrewkho andrewkho merged commit e25df94 into pytorch:main Jan 28, 2025
38 of 39 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
CLA Signed This label is managed by the Facebook bot. Authors need to sign the CLA before a PR can be reviewed.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Stateful DL] Pre-emptive: ensure compatibility with out-of-order updates to torch.utils.data.DataLoader
3 participants