diff --git a/.github/trigger_files/beam_PreCommit_Java.json b/.github/trigger_files/beam_PreCommit_Java.json new file mode 100644 index 000000000000..5abe02fc09c7 --- /dev/null +++ b/.github/trigger_files/beam_PreCommit_Java.json @@ -0,0 +1,4 @@ +{ + "comment": "Modify this file in a trivial way to cause this test suite to run.", + "modification": 1 +} diff --git a/sdks/go/pkg/beam/runners/prism/internal/execute.go b/sdks/go/pkg/beam/runners/prism/internal/execute.go index 427f1eb7145d..ab041da314dc 100644 --- a/sdks/go/pkg/beam/runners/prism/internal/execute.go +++ b/sdks/go/pkg/beam/runners/prism/internal/execute.go @@ -147,11 +147,13 @@ func executePipeline(ctx context.Context, wks map[string]*worker.W, j *jobservic config := engine.Config{} m := j.PipelineOptions().AsMap() - for _, exp := range m["beam:option:experiments:v1"].([]interface{}) { - if expStr, ok := exp.(string); ok { - if expStr == "prism_enable_rtc" { - config.EnableRTC = true - break // Found it, no need to check the rest of the slice + if experimentsSlice, ok := m["beam:option:experiments:v1"].([]interface{}); ok { + for _, exp := range experimentsSlice { + if expStr, ok := exp.(string); ok { + if expStr == "prism_enable_rtc" { + config.EnableRTC = true + break // Found it, no need to check the rest of the slice + } } } }