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 8ad47d8 Merge pull request #16031 from [BEAM-13296][Playground][Bugfix] remove redundant code from controller add e3fa4bf [BEAM-13003] Integration Test for DebeziumIO that connects to PostgresSQL add 124a525 Merge pull request #16041 from [BEAM-13003] Integration Test for DebeziumIO that connects to Postgreā¦ add b70dab8 Merge pull request #16030 from [BEAM-13219][Playground] Initialise structure to find and validate tagged files add b78de49 Merge pull request #15996 from [BEAM-13156][Playground] Implement streaming output for the run code logs add 48e5741 Merge pull request #16002 from [BEAM-13101] [Playground] load examples using the api add a7ee0ea Merge pull request #16016 from [BEAM-13089][Playground] Enable playgroundPrecommit to run on GitHub Actions for pull requests add 0be5eb3 Merge pull request #16046 from [BEAM-13295] [Playground] [Bugfix] Implement copying a prepared go.mod add d2c2a97 Merge pull request #16048 from [Beam-13256] [Playground] Implement an example verification method add 580b481 Merge pull request #16026 from [BEAM-13208][Playground] Separate stderr from stdout for code processing steps add 58c9cc3 Append to state in chunks. (#15983) add d76641a Increase the timeout for LoadTest Jenkins jobs 4h->12h. add 728fef5 [BEAM-13301] Increase the timeout for LoadTest Jenkins jobs 4h->12h. #16042 add f5e0b08 [BEAM-13073] UseParallelGC on Java container add b1807ca [BEAM-13073] UseParallelGC on Java container #16045 add a92bc09 [BEAM-13313] Fix WindowingStrategy proto to use snake case field names. add e51c7a2 Merge pull request #16054 from lukecwik/beam13313 No new revisions were added by this update. Summary of changes: .github/workflows/build_playground_backend.yml | 16 +- .github/workflows/build_playground_frontend.yml | 12 +- .test-infra/jenkins/LoadTestsBuilder.groovy | 2 +- build.gradle.kts | 8 +- .../pipeline/src/main/proto/beam_runner_api.proto | 2 +- playground/backend/build.gradle.kts | 25 + playground/backend/cmd/server/controller.go | 22 +- playground/backend/cmd/server/controller_test.go | 16 + playground/backend/env_setup.sh | 22 +- playground/backend/internal/api/v1/api.pb.go | 4 +- playground/backend/internal/cache/cache.go | 3 + .../internal/code_processing/code_processing.go | 100 +- .../code_processing/code_processing_test.go | 79 ++ playground/backend/internal/environment/beam.go | 10 +- .../backend/internal/environment/beam_test.go | 57 ++ .../internal/environment/environment_service.go | 7 +- .../environment/environment_service_test.go | 10 +- playground/backend/internal/fs_tool/fs.go | 45 + playground/backend/internal/fs_tool/fs_test.go | 113 +++ .../setup_tools/life_cycle/life_cycle_setuper.go | 13 +- .../life_cycle/life_cycle_setuper_test.go | 20 +- .../internal/streaming/run_output_writer.go | 60 ++ .../internal/streaming/run_output_writer_test.go | 123 +++ playground/frontend/analysis_options.yaml | 3 +- playground/frontend/build.gradle | 6 + playground/frontend/lib/api/v1/api.pb.dart | 1 + playground/frontend/lib/api/v1/api.pbenum.dart | 1 + playground/frontend/lib/api/v1/api.pbjson.dart | 1 + .../modules/editor/components/editor_textarea.dart | 2 +- .../example_list/category_expansion_panel.dart | 1 + .../example_list/expansion_panel_item.dart | 13 +- .../components/search_field/search_field.dart | 16 +- .../lib/modules/examples/example_selector.dart | 14 +- .../modules/examples/models/category_model.dart | 2 +- .../lib/modules/examples/models/example_model.dart | 24 +- .../{category_model.dart => outputs_model.dart} | 11 +- .../example_client/example_client.dart} | 30 +- .../example_client/grpc_example_client.dart | 171 ++++ .../examples/repositories/example_repository.dart | 115 +-- .../models/get_example_request.dart} | 9 +- .../models/get_example_response.dart} | 9 +- .../models/get_list_of_examples_request.dart} | 10 +- .../models/get_list_of_examples_response.dart} | 10 +- .../output_header/output_placements.dart | 2 +- .../lib/modules/sdk/components/sdk_selector.dart | 28 +- .../components/playground_page_providers.dart | 12 +- .../lib/pages/playground/playground_page.dart | 10 +- .../playground/states/example_selector_state.dart | 8 +- .../pages/playground/states/examples_state.dart | 59 +- .../pages/playground/states/playground_state.dart | 35 +- playground/frontend/pubspec.lock | 2 +- .../states/example_selector_state_test.dart | 91 +- .../states/example_selector_state_test.mocks.dart | 89 ++ .../playground/states/mocks/categories_mock.dart | 143 +-- .../playground/states/mocks/example_mock.dart | 29 +- .../playground/states/playground_state_test.dart | 10 +- playground/infrastructure/api/api_pb2.py | 1059 -------------------- playground/infrastructure/api/api_pb2_grpc.py | 319 ------ playground/infrastructure/api/v1/api_pb2.py | 1039 +++++++++++++++++++ playground/infrastructure/api/v1/api_pb2_grpc.py | 319 ++++++ playground/infrastructure/cd_helper.py | 54 + playground/infrastructure/{config.py => ci_cd.py} | 31 +- playground/infrastructure/ci_helper.py | 77 ++ playground/infrastructure/config.py | 7 + playground/infrastructure/grpc_client.py | 4 +- playground/infrastructure/helper.py | 72 ++ playground/infrastructure/logger.py | 42 + .../{config.py => test_cd_helper.py} | 16 +- playground/infrastructure/test_ci_cd.py | 46 + .../{config.py => test_ci_helper.py} | 16 +- playground/infrastructure/test_grpc_client.py | 17 +- sdks/java/container/boot.go | 3 + sdks/java/io/debezium/build.gradle | 2 + .../debezium/DebeziumIOPostgresSqlConnectorIT.java | 101 ++ .../apache_beam/runners/worker/sdk_worker.py | 37 +- sdks/python/apache_beam/transforms/core.py | 2 +- 76 files changed, 3110 insertions(+), 1889 deletions(-) create mode 100644 playground/backend/internal/environment/beam_test.go create mode 100644 playground/backend/internal/streaming/run_output_writer.go create mode 100644 playground/backend/internal/streaming/run_output_writer_test.go copy playground/frontend/lib/modules/examples/models/{category_model.dart => outputs_model.dart} (80%) copy playground/frontend/lib/{pages/playground/states/examples_state.dart => modules/examples/repositories/example_client/example_client.dart} (51%) create mode 100644 playground/frontend/lib/modules/examples/repositories/example_client/grpc_example_client.dart copy playground/frontend/lib/modules/examples/{models/category_model.dart => repositories/models/get_example_request.dart} (80%) copy playground/frontend/lib/modules/examples/{models/category_model.dart => repositories/models/get_example_response.dart} (80%) copy playground/frontend/lib/modules/examples/{models/category_model.dart => repositories/models/get_list_of_examples_request.dart} (78%) copy playground/frontend/lib/modules/examples/{models/category_model.dart => repositories/models/get_list_of_examples_response.dart} (75%) create mode 100644 playground/frontend/test/pages/playground/states/example_selector_state_test.mocks.dart delete mode 100644 playground/infrastructure/api/api_pb2.py delete mode 100644 playground/infrastructure/api/api_pb2_grpc.py create mode 100644 playground/infrastructure/api/v1/api_pb2.py create mode 100644 playground/infrastructure/api/v1/api_pb2_grpc.py create mode 100644 playground/infrastructure/cd_helper.py copy playground/infrastructure/{config.py => ci_cd.py} (53%) create mode 100644 playground/infrastructure/ci_helper.py create mode 100644 playground/infrastructure/helper.py create mode 100644 playground/infrastructure/logger.py copy playground/infrastructure/{config.py => test_cd_helper.py} (69%) create mode 100644 playground/infrastructure/test_ci_cd.py copy playground/infrastructure/{config.py => test_ci_helper.py} (67%) create mode 100644 sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java