This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f3be4c4275b Add test to cover SDF with side input data correctness
(#35951)
add 8e0f35fed36 Adds a pipeline option to terminate processing of an
element after a timeout (python) (#35391)
No new revisions were added by this update.
Summary of changes:
.../python/apache_beam/options/pipeline_options.py | 8 +++
.../apache_beam/options/pipeline_options_test.py | 10 ++-
.../apache_beam/runners/worker/sdk_worker.py | 11 ++--
.../apache_beam/runners/worker/sdk_worker_main.py | 20 +++++-
.../apache_beam/runners/worker/worker_status.py | 55 ++++++++++++----
.../runners/worker/worker_status_test.py | 75 ++++++++++++----------
6 files changed, 125 insertions(+), 54 deletions(-)
