This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch prismDisconnect
in repository https://gitbox.apache.org/repos/asf/beam.git
from 072da96afd0 [prism] Fail jobs on SDK disconnect.
add 5e8498f31ff Reduce flaky short bame for passert test.
add 2bfe351fe02 [prism] better workerID, warn on pre-bundle fail, buffer
done chan
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/runners/prism/internal/execute.go | 6 ++---
sdks/go/pkg/beam/runners/prism/internal/stage.go | 2 +-
.../beam/runners/prism/internal/worker/bundle.go | 9 ++++---
.../runners/prism/internal/worker/bundle_test.go | 2 +-
.../beam/runners/prism/internal/worker/worker.go | 30 +++++++++++-----------
.../runners/prism/internal/worker/worker_test.go | 10 ++++----
sdks/go/pkg/beam/testing/passert/equals_test.go | 2 +-
7 files changed, 32 insertions(+), 29 deletions(-)
