-
Notifications
You must be signed in to change notification settings - Fork 47
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
Init Implementation per_stream
batching
#438
base: main
Are you sure you want to change the base?
Conversation
for more information, see https://pre-commit.ci
…data into per_stream_batching
for more information, see https://pre-commit.ci
for more information, see https://pre-commit.ci
for more information, see https://pre-commit.ci
@tchaton When is the I'm trying to send messages to iterators and process them within their worker loops -- when the iterator must change it's dataset index (i.e., on batch boundaries). I'm getting confused by the difference between |
per_stream
batching
for batch in super().__iter__(): | ||
print("Fetched a batch ...") |
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.
maybe use loggier instead of print
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #438 +/- ##
===================================
- Coverage 78% 78% -0%
===================================
Files 35 35
Lines 5106 5141 +35
===================================
+ Hits 4006 4024 +18
- Misses 1100 1117 +17 |
Before submitting
What does this PR do?
Fixes #434
PR review
Anyone in the community is free to review the PR once the tests have passed.
If we didn't discuss your PR in GitHub issues there's a high chance it will not be merged.
Did you have fun?
Make sure you had fun coding 🙃