-
Couldn't load subscription status.
- Fork 3.1k
[DistDataloader] Update implementation, add nested.py #8380
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
Conversation
|
Thanks for your contribution! |
a1378a3 to
ac3f1aa
Compare
| data = None | ||
| if self._need_data: | ||
| try: | ||
| data = next(self._dataloader_iter) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
copy可以放到这里
| data = next(self._dataloader_iter) | |
| data = next(self._dataloader_iter) | |
| data = nested_copy_place(data, place=paddle.framework._current_expected_place()) |
paddlenlp/data/dist_dataloader.py
Outdated
| nested_reduce_tensor, | ||
| ) | ||
|
|
||
| _MAX_DATA_DIM = 64 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
删除吧,应该没用
dabda13 to
84b4bf7
Compare
paddlenlp/trainer/trainer.py
Outdated
| num_workers=self.args.dataloader_num_workers, | ||
| ) | ||
| if self.args.distributed_dataloader: | ||
| return _DataLoader( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
既然都这样了,这里就直接 DistDataLoader 吧
删掉_DataLoader = DistDataLoader if self.args.distributed_dataloader else DataLoader
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## develop #8380 +/- ##
===========================================
+ Coverage 55.42% 55.43% +0.01%
===========================================
Files 615 616 +1
Lines 96235 96209 -26
===========================================
+ Hits 53335 53336 +1
+ Misses 42900 42873 -27 ☔ View full report in Codecov by Sentry. |
) * Fix sharding overlap bug * [DistDataloader] Update implementation, add nested.py * Fix pipeline * add first try * update dataloader --------- Co-authored-by: lugimzzz <[email protected]>
) * Fix sharding overlap bug * [DistDataloader] Update implementation, add nested.py * Fix pipeline * add first try * update dataloader --------- Co-authored-by: lugimzzz <[email protected]>
PR types
Bug fixes
PR changes
Others
Description