You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Robert Burke (Jira)" <ji...@apache.org> on 2021/10/08 22:06:00 UTC

[jira] [Created] (BEAM-13024) [Go SDK] Export flags to PipelineOptions on non-dataflow runners.

Robert Burke created BEAM-13024:
-----------------------------------

             Summary: [Go SDK] Export flags to PipelineOptions on non-dataflow runners.
                 Key: BEAM-13024
                 URL: https://issues.apache.org/jira/browse/BEAM-13024
             Project: Beam
          Issue Type: Bug
          Components: sdk-go
            Reporter: Robert Burke


Recently the Go SDK dataflow runner code began adding explicitly set flags to the pipeline options. This made them available to worker code at execution time, if queried with `beam.PipelineOptions.Get`. 

The proposal is to generalize this code and make use of it in all runners (including the direct runner). 

Flag filtering and adding here:
https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/runners/dataflow/dataflow.go#L281



--
This message was sent by Atlassian Jira
(v8.3.4#803005)