in main.go [46:58]
func main() {
flag.Parse()
beam.Init()
ctx := context.Background()
pipeline, scope := beam.NewPipelineWithRoot()
myPipeline(scope, *input_text)
// Run the pipeline. You can specify your runner with the --runner flag.
if err := beamx.Run(ctx, pipeline); err != nil {
log.Fatalf("Failed to execute job: %v", err)
}
}