You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2019/01/23 19:33:15 UTC
[beam] branch master updated: Fix ptest runner selection.
This is an automated email from the ASF dual-hosted git repository.
altay 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 e9d3ce2 Fix ptest runner selection.
new 0091b3c Merge pull request #7608 from lostluck/fixptest
e9d3ce2 is described below
commit e9d3ce2bbac7d65d8e19ad946eb149599559c62a
Author: Robert Burke <ro...@frantil.com>
AuthorDate: Wed Jan 23 19:25:42 2019 +0000
Fix ptest runner selection.
---
sdks/go/pkg/beam/testing/ptest/ptest.go | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/sdks/go/pkg/beam/testing/ptest/ptest.go b/sdks/go/pkg/beam/testing/ptest/ptest.go
index 008591b..fe23f6c 100644
--- a/sdks/go/pkg/beam/testing/ptest/ptest.go
+++ b/sdks/go/pkg/beam/testing/ptest/ptest.go
@@ -62,11 +62,17 @@ func CreateList2(a, b interface{}) (*beam.Pipeline, beam.Scope, beam.PCollection
//
// The test file must have a TestMain that calls Main or MainWithDefault
// to function.
-var Runner = flag.String("runner", "direct", "Pipeline runner.")
+var (
+ Runner = flag.String("runner", "", "Pipeline runner.")
+ defaultRunner = "direct"
+)
// Run runs a pipeline for testing. The semantics of the pipeline is expected
// to be verified through passert.
func Run(p *beam.Pipeline) error {
+ if *Runner == "" {
+ *Runner = defaultRunner
+ }
return beam.Run(context.Background(), *Runner, p)
}
@@ -87,13 +93,10 @@ func Main(m *testing.M) {
// pipelines on runners other than the direct runner, while setting the default
// runner to use.
func MainWithDefault(m *testing.M, runner string) {
+ defaultRunner = runner
if !flag.Parsed() {
flag.Parse()
}
- // Override if not otherwise set.
- if *Runner == "direct" {
- *Runner = runner
- }
beam.Init()
os.Exit(m.Run())
}