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
