-
Notifications
You must be signed in to change notification settings - Fork 4.3k
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
[Python] use get_buffer to fetch buffer when the buffer is None #27373
Conversation
Codecov Report
@@ Coverage Diff @@
## master #27373 +/- ##
==========================================
- Coverage 71.31% 71.19% -0.12%
==========================================
Files 862 862
Lines 105199 104659 -540
==========================================
- Hits 75025 74516 -509
+ Misses 28624 28593 -31
Partials 1550 1550
Flags with carried forward coverage won't be shown. Click here to find out more.
... and 32 files with indirect coverage changes 📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
Outdated
Show resolved
Hide resolved
sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
Outdated
Show resolved
Hide resolved
sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
Outdated
Show resolved
Hide resolved
R: @pabloem cc: @tvalentyn , @liferoad |
Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control |
I tested the TFX test mentioned at #25315 (comment). It is working |
sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
Outdated
Show resolved
Hide resolved
sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
Outdated
Show resolved
Hide resolved
this LGTM! Thanks so much @AnandInguva - can you add a test case? Feel free to merge after adding the test case. |
Done. Test fails without the above change |
Lint error is not related to this PR |
…he#27373) * Create empty ListBuffer when buffer is none * Replace empty buffer with a List/GroupBuffer * Apply suggestions from code review * Fix mypy error * Update sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py * Add test * Add note to CHANGES.md * Fix link in CHANGES.md
…ne (apache#27373)" (apache#27491) This reverts commit 63d5171.
…he#27373) * Create empty ListBuffer when buffer is none * Replace empty buffer with a List/GroupBuffer * Apply suggestions from code review * Fix mypy error * Update sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py * Add test * Add note to CHANGES.md * Fix link in CHANGES.md
…ne (apache#27373)" (apache#27491) This reverts commit 63d5171.
Fixes: #25315
Fixes: #23228
Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:
addresses #123
), if applicable. This will automatically add a link to the pull request in the issue. If you would like the issue to automatically close on merging the pull request, commentfixes #<ISSUE NUMBER>
instead.CHANGES.md
with noteworthy changes.See the Contributor Guide for more tips on how to make review process smoother.
To check the build health, please visit https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md
GitHub Actions Tests Status (on master branch)
See CI.md for more information about GitHub Actions CI.