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 64b4aa6fdde Memoize toString() for MetricKey and MetricName (#32379)
add 9771a425655 Add WindowedvalueParam option to DoFns.
add b875fd490d9 Merge pull request #32305 Add WindowedValueParam option to
DoFns.
add 6baba928348 [YAML] Better errors for unconsumed error outputs. (#32341)
add f8bda18c737 Use proper coders in interactive cache.
add f06df5dabf0 Merge pull request #32330 Use proper coders in interactive
cache.
add 2b02fd3cc94 Allow ib.collect to work with non-interactive runners.
(#32383)
add 34a7c4f4198 Upgrade artifact actions to v4 (#32391)
add 696978018ed Bump actions/download-artifact from 4.1.7 to 4.1.8 (#32396)
add 3b4ecd7a987 Bump commons-cli:commons-cli from 1.8.0 to 1.9.0 (#32350)
add 4dddde4e6de Colab Notebook for Unit Tests in Beam (#32336)
add 6901d7c8623 Undo part of artifact action upgrade to fix workflow
(#32401)
add 1ee2f6bff4a Bump jinja2 version to resolve vulnerability (#32403)
add 50a6cd2b580 Add tests of using ib.collect(...) without
InteractiveRunner.
add d5dc20000d5 Allow ib.collect(...) to take multiple PCollections.
add a7852d9ddb1 Merge pull request #32392 Allow ib.collect(...) to take
multiple PCollections.
No new revisions were added by this update.
Summary of changes:
.github/workflows/build_wheels.yml | 24 +-
.github/workflows/python_tests.yml | 2 +-
examples/notebooks/blog/unittests_in_beam.ipynb | 362 +++++++++++++++++++++
release/build.gradle.kts | 4 +-
sdks/python/apache_beam/pipeline_test.py | 14 +
sdks/python/apache_beam/runners/common.py | 6 +
.../runners/interactive/cache_manager.py | 50 ++-
.../runners/interactive/cache_manager_test.py | 7 +-
.../runners/interactive/interactive_beam.py | 98 ++++--
.../runners/interactive/interactive_runner_test.py | 46 ++-
.../interactive/non_interactive_runner_test.py | 262 +++++++++++++++
.../runners/interactive/pipeline_fragment.py | 50 ++-
.../runners/interactive/pipeline_fragment_test.py | 8 -
.../runners/interactive/recording_manager.py | 9 +-
.../runners/interactive/recording_manager_test.py | 2 +-
.../apache_beam/runners/interactive/utils.py | 3 +
sdks/python/apache_beam/transforms/core.py | 2 +
sdks/python/apache_beam/yaml/yaml_transform.py | 9 +-
.../apache_beam/yaml/yaml_transform_unit_test.py | 3 +-
.../container/py310/base_image_requirements.txt | 2 +-
.../container/py311/base_image_requirements.txt | 2 +-
.../container/py312/base_image_requirements.txt | 2 +-
.../container/py38/base_image_requirements.txt | 2 +-
.../container/py39/base_image_requirements.txt | 2 +-
sdks/python/setup.py | 7 +-
.../content/en/documentation/sdks/yaml-errors.md | 5 +-
26 files changed, 880 insertions(+), 103 deletions(-)
create mode 100644 examples/notebooks/blog/unittests_in_beam.ipynb
create mode 100644
sdks/python/apache_beam/runners/interactive/non_interactive_runner_test.py
