This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch nightly-refs/heads/master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 939af65 [BEAM-13015] Use a DirectExecutor for state since we are just completing futures on the callback. (#16745) add 2b012d0 Build wheels for Python 3.9 add 51d1fb2 [BEAM-12000] Build wheels for Python 3.9 #16964 add 0702451 Merge pull request #16892 from [BEAM-13755] [Playground] Scroll the opened example to the context line add 75b4100 Merge pull request #16880 from [BEAM-13963][Playground] Get bucket name from environment variable add a441847 Merge pull request #16870 from [BEAM-13874][Playground] Tag multifile examples add af50774 Merge pull request #16910 from [BEAM-13724] [Playground] Get the default example on the frontend add 6433594 [BEAM-14008] Fix incorrect guava import (#16966) add d9d3c93 Fix ignored exception in BatchSpannerRead. (#16960) add 5a8bb08 [BEAM-13917] Improve coverage of databaseio package (#16956) add 3070d5f [BEAM-13925] Add entry files to process new prs and pr updates for PR automation (#16950) add 0631a5e [BEAM-13899] Improve coverage of debug package (#16951) add 6b06cbb [BEAM-13907] Improve coverage of textio package (#16937) No new revisions were added by this update. Summary of changes: .github/workflows/build_wheels.yml | 8 +- .../apache/beam/examples/WindowedWordCount.java | 13 ++ .../org/apache/beam/examples/complete/TfIdf.java | 12 ++ .../examples/complete/TopWikipediaSessions.java | 13 ++ .../beam/examples/complete/TrafficMaxLaneFlow.java | 13 ++ .../beam/examples/complete/TrafficRoutes.java | 14 ++ .../katas/python/IO/TextIO/ReadFromText/task.py | 2 +- playground/backend/cmd/server/controller.go | 10 +- playground/backend/cmd/server/server.go | 6 +- playground/backend/containers/go/Dockerfile | 1 + playground/backend/containers/java/Dockerfile | 1 + playground/backend/containers/python/Dockerfile | 1 + playground/backend/containers/router/Dockerfile | 1 + playground/backend/containers/scio/Dockerfile | 1 + .../internal/cloud_bucket/precompiled_objects.go | 31 +-- .../cloud_bucket/precompiled_objects_test.go | 7 +- .../backend/internal/environment/application.go | 11 +- .../internal/environment/environment_service.go | 5 +- .../environment/environment_service_test.go | 6 +- .../internal/utils/precompiled_objects_utils.go | 4 +- .../modules/editor/components/editor_textarea.dart | 94 ++++++--- .../lib/modules/examples/models/example_model.dart | 2 + .../example_client/example_client.dart | 5 + .../example_client/grpc_example_client.dart | 25 ++- .../examples/repositories/example_repository.dart | 8 + .../models/get_default_example_response.dart | 12 +- .../lib/modules/sdk/components/sdk_selector.dart | 2 +- .../components/playground_page_providers.dart | 21 +- .../pages/playground/states/examples_state.dart | 55 +++-- scripts/ci/pr-bot/.gitignore | 38 ++++ scripts/ci/pr-bot/Commands.md | 32 +++ scripts/ci/pr-bot/processNewPrs.ts | 226 +++++++++++++++++++++ scripts/ci/pr-bot/processPrUpdate.ts | 208 +++++++++++++++++++ scripts/ci/pr-bot/shared/githubUtils.ts | 8 + scripts/ci/pr-bot/shared/userCommand.ts | 6 +- sdks/go.mod | 1 + sdks/go.sum | 8 +- sdks/go/pkg/beam/io/databaseio/database_test.go | 86 ++++++++ sdks/go/pkg/beam/io/textio/sdf_test.go | 14 +- sdks/go/pkg/beam/io/textio/textio_test.go | 71 ++++++- .../beam/x/debug/head_test.go} | 31 +-- sdks/go/pkg/beam/x/debug/print_test.go | 101 +++++++++ .../beam/sdk/fn/channel/ManagedChannelFactory.java | 2 +- .../beam/sdk/io/gcp/spanner/BatchSpannerRead.java | 3 +- .../beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 127 ++++++++++-- .../examples/complete/game/user_score.py | 13 ++ 46 files changed, 1215 insertions(+), 144 deletions(-) copy learning/katas/java/IO/Built-in IOs/Built-in IOs/test/org/apache/beam/learning/katas/io/builtinios/TaskTest.java => playground/frontend/lib/modules/examples/repositories/models/get_default_example_response.dart (81%) create mode 100644 scripts/ci/pr-bot/.gitignore create mode 100644 scripts/ci/pr-bot/Commands.md create mode 100644 scripts/ci/pr-bot/processNewPrs.ts create mode 100644 scripts/ci/pr-bot/processPrUpdate.ts create mode 100644 sdks/go/pkg/beam/io/databaseio/database_test.go copy sdks/go/{test/regression/lperror_test.go => pkg/beam/x/debug/head_test.go} (60%) create mode 100644 sdks/go/pkg/beam/x/debug/print_test.go