This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 8d77c8fad07 Add try-excepts around data sampler encoding (#31396)
add 0b5ffd7d153 Add SDK capability to detect if the SDK Fn Harness data
channel is busy or not (#31420)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 15 +++++++++++++--
sdks/go/pkg/beam/core/runtime/exec/datasource_test.go | 8 ++++++--
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 12 +++++++-----
sdks/go/pkg/beam/core/runtime/harness/harness.go | 9 +++++----
sdks/go/pkg/beam/core/runtime/harness/monitoring.go | 8 ++++----
.../beam/sdk/fn/data/BeamFnDataInboundObserver.java | 14 ++++++++++++++
.../apache/beam/sdk/util/construction/Environments.java | 1 +
.../beam/fn/harness/control/ProcessBundleHandler.java | 3 +++
.../python/apache_beam/runners/worker/bundle_processor.py | 9 +++++++++
sdks/python/apache_beam/runners/worker/sdk_worker.py | 5 ++++-
sdks/python/apache_beam/runners/worker/sdk_worker_test.py | 4 ++--
sdks/python/apache_beam/transforms/environments.py | 1 +
12 files changed, 69 insertions(+), 20 deletions(-)
