This is an automated email from the ASF dual-hosted git repository.
shunping pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new ff7c3893bb6 Fix an issue when running a pipeline with prism runner on
docker in python. (#36002)
ff7c3893bb6 is described below
commit ff7c3893bb6108057dbe233bd79a18daf22b8014
Author: Shunping Huang <[email protected]>
AuthorDate: Thu Aug 28 16:18:59 2025 -0400
Fix an issue when running a pipeline with prism runner on docker in python.
(#36002)
---
sdks/go/pkg/beam/runners/prism/internal/worker/worker.go | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/sdks/go/pkg/beam/runners/prism/internal/worker/worker.go
b/sdks/go/pkg/beam/runners/prism/internal/worker/worker.go
index 1141a5b0230..f6c43a52068 100644
--- a/sdks/go/pkg/beam/runners/prism/internal/worker/worker.go
+++ b/sdks/go/pkg/beam/runners/prism/internal/worker/worker.go
@@ -156,6 +156,14 @@ func (wk *W) GetProvisionInfo(_ context.Context, _
*fnpb.GetProvisionInfoRequest
endpoint := &pipepb.ApiServiceDescriptor{
Url: wk.Endpoint(),
}
+
+ var rt string
+ if len(wk.EnvPb.GetDependencies()) > 0 {
+ rt = wk.JobKey
+ } else {
+ rt = "__no_artifacts_staged__"
+ }
+
resp := &fnpb.GetProvisionInfoResponse{
Info: &fnpb.ProvisionInfo{
// TODO: Include runner capabilities with the per job
configuration.
@@ -168,7 +176,7 @@ func (wk *W) GetProvisionInfo(_ context.Context, _
*fnpb.GetProvisionInfoRequest
Url: wk.ArtifactEndpoint,
},
- RetrievalToken: wk.JobKey,
+ RetrievalToken: rt,
Dependencies: wk.EnvPb.GetDependencies(),
PipelineOptions: wk.PipelineOptions,
