You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by gi...@apache.org on 2025/06/20 04:06:58 UTC

(beam) branch nightly-refs/heads/master updated (3736c9b193e -> da1768f18c0)

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 3736c9b193e Add dynamic read support to KafkaIO in Python SDK (#35292)
     add 8e4665ef8ae added timeout for Direct_Read with Bigquery IO (#35284)
     add b4cda14d237 Bump cloud.google.com/go/profiler from 0.4.2 to 0.4.3 in /sdks (#35364)
     add da1768f18c0 Add Async Dofn and Test to BEAM (#35245)

No new revisions were added by this update.

Summary of changes:
 sdks/go.mod                                        |   6 +-
 sdks/go.sum                                        |  12 +-
 sdks/python/apache_beam/io/gcp/bigquery.py         |  32 +-
 sdks/python/apache_beam/transforms/async_dofn.py   | 431 ++++++++++++++++++++
 .../apache_beam/transforms/async_dofn_test.py      | 448 +++++++++++++++++++++
 5 files changed, 911 insertions(+), 18 deletions(-)
 create mode 100644 sdks/python/apache_beam/transforms/async_dofn.py
 create mode 100644 sdks/python/apache_beam/transforms/async_dofn_test.py