[Python] use get_buffer to fetch buffer when the buffer is None#27373
[Python] use get_buffer to fetch buffer when the buffer is None#27373AnandInguva merged 9 commits intomasterfrom
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.mdwith 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.