Repository: beam Updated Branches: refs/heads/master b82195aa0 -> b44056fc6
[BEAM-3031] Use blocking grpc dial in Go unit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7aae2141 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7aae2141 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7aae2141 Branch: refs/heads/master Commit: 7aae2141b33bf58364ff5b8e9bc8bda17794100c Parents: b82195a Author: Henning Rohde <hero...@google.com> Authored: Fri Oct 6 15:24:20 2017 -0700 Committer: Henning Rohde <hero...@google.com> Committed: Fri Oct 6 15:24:20 2017 -0700 ---------------------------------------------------------------------- sdks/go/pkg/beam/artifact/server_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/7aae2141/sdks/go/pkg/beam/artifact/server_test.go ---------------------------------------------------------------------- diff --git a/sdks/go/pkg/beam/artifact/server_test.go b/sdks/go/pkg/beam/artifact/server_test.go index d5d5496..da17544 100644 --- a/sdks/go/pkg/beam/artifact/server_test.go +++ b/sdks/go/pkg/beam/artifact/server_test.go @@ -26,6 +26,7 @@ import ( "github.com/apache/beam/sdks/go/pkg/beam/util/grpcx" "golang.org/x/net/context" "google.golang.org/grpc" + "time" ) // startServer starts an in-memory staging and retrieval artifact server @@ -47,7 +48,7 @@ func startServer(t *testing.T) *grpc.ClientConn { t.Logf("server listening on %v", endpoint) - cc, err := grpc.Dial(endpoint, grpc.WithInsecure()) + cc, err := grpcx.Dial(context.Background(), endpoint, time.Minute) if err != nil { t.Fatalf("failed to dial fake server at %v: %v", endpoint, err) }
