You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2020/04/08 05:21:36 UTC

[beam] branch lostluck-protosuffix updated: Update provision.go

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

lostluck pushed a commit to branch lostluck-protosuffix
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/lostluck-protosuffix by this push:
     new 209508c  Update provision.go
209508c is described below

commit 209508c258099cef4ff1988e137f8e93f2d5b1e6
Author: Robert Burke <lo...@users.noreply.github.com>
AuthorDate: Tue Apr 7 22:21:25 2020 -0700

    Update provision.go
---
 sdks/go/cmd/beamctl/cmd/provision.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/sdks/go/cmd/beamctl/cmd/provision.go b/sdks/go/cmd/beamctl/cmd/provision.go
index 199ef54..3f53a84 100644
--- a/sdks/go/cmd/beamctl/cmd/provision.go
+++ b/sdks/go/cmd/beamctl/cmd/provision.go
@@ -16,7 +16,7 @@
 package cmd
 
 import (
-	pb "github.com/apache/beam/sdks/go/pkg/beam/model/fnexecution_v1"
+	fnpb "github.com/apache/beam/sdks/go/pkg/beam/model/fnexecution_v1"
 	"github.com/golang/protobuf/proto"
 	"github.com/spf13/cobra"
 )
@@ -46,9 +46,9 @@ func infoFn(cmd *cobra.Command, args []string) error {
 	}
 	defer cc.Close()
 
-	client := pb.NewProvisionServiceClient(cc)
+	client := fnpb.NewProvisionServiceClient(cc)
 
-	info, err := client.GetProvisionInfo(ctx, &pb.GetProvisionInfoRequest{})
+	info, err := client.GetProvisionInfo(ctx, &fnpb.GetProvisionInfoRequest{})
 	if err != nil {
 		return err
 	}