Adds a pipeline option to terminate processing of an element after a timeout (python)#35391
Conversation
|
Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment |
|
R: @apanich |
|
Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control. If you'd like to restart, comment |
Co-authored-by: Ryan Mbuashu-Ndip <mbuashundip@google.com>
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #35391 +/- ##
============================================
+ Coverage 54.50% 54.54% +0.03%
Complexity 1559 1559
============================================
Files 1035 1037 +2
Lines 161595 162038 +443
Branches 1139 1139
============================================
+ Hits 88084 88390 +306
- Misses 71380 71517 +137
Partials 2131 2131
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
ryan-mbuashundip
left a comment
There was a problem hiding this comment.
Please add @kennknowles as a reviewer.
|
R: @kennknowles |
tvalentyn
left a comment
There was a problem hiding this comment.
please fix the lint as well.
Address the issue #35174 in Python SDK
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 or the workflows README to see a list of phrases to trigger workflows.