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
}