[beam] branch master updated: [BEAM-13419] Check for initialization in dataflow runner (#16765)

[lostluck]

This is an automated email from the ASF dual-hosted git repository.

lostluck 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 5e8c258  [BEAM-13419] Check for initialization in dataflow runner 
(#16765)
5e8c258 is described below

commit 5e8c25838b90870c1ca604e3fe02887a6393d876
Author: Danny McCormick <dannymccorm...@google.com>
AuthorDate: Mon Feb 7 15:51:22 2022 -0500

    [BEAM-13419] Check for initialization in dataflow runner (#16765)
---
 sdks/go/pkg/beam/runners/dataflow/dataflow.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sdks/go/pkg/beam/runners/dataflow/dataflow.go 
b/sdks/go/pkg/beam/runners/dataflow/dataflow.go
index 89c3797..4cd877f 100644
--- a/sdks/go/pkg/beam/runners/dataflow/dataflow.go
+++ b/sdks/go/pkg/beam/runners/dataflow/dataflow.go
@@ -155,6 +155,10 @@ var unique int32
 // Execute runs the given pipeline on Google Cloud Dataflow. It uses the
 // default application credentials to submit the job.
 func Execute(ctx context.Context, p *beam.Pipeline) (beam.PipelineResult, 
error) {
+       if !beam.Initialized() {
+               panic("Beam has not been initialized. Call beam.Init() before 
pipeline construction.")
+       }
+
        // (1) Gather job options
 
        project := gcpopts.GetProjectFromFlagOrEnvironment(ctx)