[beam] branch nightly-refs/heads/master updated (6667eb4741b -> 921bc7b9470)

[gi...@apache.org]

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 6667eb4741b [#24789][prism] add preprocessor and test (#25520)
     add 6e53f13871a Bump github.com/tetratelabs/wazero from 1.0.0-pre.7 to 1.0.0-pre.9 in /sdks (#25560)
     add bc0284b5cae [#24789][prism] Add testdofns for later (#25557)
     add fc4b80c091c [#24789][prism] Minimum required jobservices (#25556)
     add 85ebc2f46b0 [#24789][prism] Handlers for combine, ParDo, GBK, Flatten  (#25558)
     add 63e4c37cded [prism] Tiny lint fixes (#25564)
     add 108d097bbe9 minor error handling fixes (#25555)
     add 921bc7b9470 [prism] Add in element manager (#25565)

No new revisions were added by this update.

Summary of changes:
 sdks/go.mod                                        |   4 +-
 sdks/go.sum                                        |   4 +-
 sdks/go/examples/wasm/README.md                    |   6 +-
 sdks/go/examples/wasm/wasm.go                      |   6 +-
 sdks/go/pkg/beam/core/graph/fn.go                  |   8 +-
 sdks/go/pkg/beam/core/runtime/exec/datasink.go     |   2 +-
 .../runners/prism/internal/config/config_test.go   |   2 +-
 .../prism/internal/engine/elementmanager.go        | 675 +++++++++++++++++++++
 .../prism/internal/engine/elementmanager_test.go   | 516 ++++++++++++++++
 sdks/go/pkg/beam/runners/prism/internal/execute.go |  12 +
 .../beam/runners/prism/internal/handlecombine.go   | 209 +++++++
 .../pkg/beam/runners/prism/internal/handlepardo.go | 244 ++++++++
 .../beam/runners/prism/internal/handlerunner.go    | 298 +++++++++
 .../runners/prism/internal/jobservices/artifact.go |  81 +++
 .../beam/runners/prism/internal/jobservices/job.go | 120 ++++
 .../prism/internal/jobservices/management.go       | 142 +++++
 .../runners/prism/internal/jobservices/metrics.go  |   2 -
 .../runners/prism/internal/jobservices/server.go   |  82 +++
 .../prism/internal/jobservices/server_test.go      |  79 +++
 .../pkg/beam/runners/prism/internal/testdofns.go   | 349 +++++++++++
 .../beam/runners/prism/internal/testdofns_test.go  |  55 ++
 .../pkg/beam/runners/prism/internal/urns/urns.go   |   2 +-
 .../test/integration/primitives/checkpointing.go   |   2 +-
 23 files changed, 2881 insertions(+), 19 deletions(-)
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager_test.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/handlecombine.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/handlepardo.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/handlerunner.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/jobservices/artifact.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/jobservices/job.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/jobservices/server.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/jobservices/server_test.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/testdofns.go
 create mode 100644 sdks/go/pkg/beam/runners/prism/internal/testdofns_test.go