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 def86646cd1 feat(options): add support for comma-separated options
(#35580)
add f7071ef2799 Enable prism by default (where supported) (#34612)
add fbd330f24af workflows+gradle: capture and run ML tests that require
non self-hosted environment on `ubuntu-latest` (#35585)
add c4a60b9fcb5 Bump golang.org/x/sys from 0.33.0 to 0.34.0 in /sdks
(#35583)
add 44ee250701c Bump google.golang.org/api from 0.240.0 to 0.241.0 in
/sdks (#35554)
add 1fd8ce382d7 Bump golang.org/x/sync from 0.15.0 to 0.16.0 in /sdks
(#35591)
add 8930c8dd5f8 workflows: update `require_docker_in_docker` in `Pposargs`
(#35598)
add 6a4ff716a6d Fix bad error assert (#35596)
add e8d4395d081 Partially revert #35598 (#35600)
add cd72a255018 Fix json schema test (#35597)
add 56ca36feef8 Add a flag in PeriodicImpulse to rebase timestamp. (#35569)
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
.../beam_PostCommit_Python_Dependency.json | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Direct.json | 2 +-
.../beam_PostCommit_Python_Xlang_IO_Direct.json | 2 +-
.github/workflows/beam_PostCommit_Python.yml | 2 +-
.../beam_PostCommit_Python_Dependency.yml | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Direct.yml | 4 +-
.github/workflows/beam_PreCommit_Python_ML.yml | 2 +-
CHANGES.md | 2 +
sdks/go.mod | 6 +-
sdks/go.sum | 12 +-
.../beam/sdk/schemas/JsonSchemaConversionTest.java | 53 +++--
sdks/python/apache_beam/coders/coders_test.py | 2 +-
.../apache_beam/examples/snippets/snippets_test.py | 13 +-
.../transforms/elementwise/enrichment_test.py | 32 ++-
.../transforms/elementwise/pardo_dofn_methods.py | 2 -
sdks/python/apache_beam/io/fileio_test.py | 12 +-
.../apache_beam/io/gcp/bigquery_file_loads_test.py | 4 +-
.../io/gcp/experimental/spannerio_test.py | 2 +-
sdks/python/apache_beam/io/parquetio_test.py | 23 +-
sdks/python/apache_beam/io/requestresponse_test.py | 20 +-
sdks/python/apache_beam/metrics/metric_test.py | 5 +-
.../ml/anomaly/detectors/pyod_adapter_test.py | 18 +-
.../apache_beam/ml/anomaly/transforms_test.py | 14 +-
sdks/python/apache_beam/ml/inference/base_test.py | 6 +-
.../ml/inference/onnx_inference_test.py | 9 +-
.../ml/inference/pytorch_inference_test.py | 2 +-
.../ml/inference/tensorflow_inference_test.py | 3 +-
.../apache_beam/ml/rag/chunking/langchain_test.py | 2 +-
.../enrichment/bigquery_vector_search_it_test.py | 6 +-
sdks/python/apache_beam/ml/transforms/base_test.py | 2 +-
.../ml/transforms/embeddings/huggingface_test.py | 4 +-
.../ml/transforms/embeddings/open_ai_it_test.py | 2 +-
.../transforms/embeddings/tensorflow_hub_test.py | 2 +-
.../ml/transforms/embeddings/vertex_ai_test.py | 2 +-
sdks/python/apache_beam/pipeline_test.py | 4 +-
.../apache_beam/runners/direct/direct_runner.py | 94 +++++++--
.../runners/interactive/interactive_runner.py | 2 +
.../runners/interactive/recording_manager.py | 2 +
.../apache_beam/runners/pipeline_utils_test.py | 4 +-
sdks/python/apache_beam/testing/util_test.py | 25 ++-
.../enrichment_handlers/bigquery_it_test.py | 3 +-
.../enrichment_handlers/bigtable_it_test.py | 9 +-
.../vertex_ai_feature_store_it_test.py | 9 +-
.../apache_beam/transforms/periodicsequence.py | 40 +++-
.../transforms/periodicsequence_test.py | 35 ++-
sdks/python/apache_beam/transforms/ptransform.py | 3 +
.../apache_beam/transforms/ptransform_test.py | 234 +++++++--------------
.../transforms/timestamped_value_type_test.py | 9 +-
sdks/python/apache_beam/transforms/trigger_test.py | 7 +-
.../apache_beam/transforms/userstate_test.py | 6 +-
sdks/python/apache_beam/transforms/util_test.py | 49 ++---
.../python/apache_beam/typehints/typecheck_test.py | 106 +++-------
sdks/python/apache_beam/yaml/yaml_mapping_test.py | 8 +-
sdks/python/pytest.ini | 1 +
sdks/python/test-suites/direct/common.gradle | 28 +++
56 files changed, 523 insertions(+), 433 deletions(-)
