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

[lostluck]

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 b6e0584  Update artifact.go
b6e0584 is described below

commit b6e0584c3c21f3e6abb8eba086a8bd98c5095536
Author: Robert Burke <lostl...@users.noreply.github.com>
AuthorDate: Tue Apr 7 22:20:47 2020 -0700

    Update artifact.go
---
 sdks/go/cmd/beamctl/cmd/artifact.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/sdks/go/cmd/beamctl/cmd/artifact.go 
b/sdks/go/cmd/beamctl/cmd/artifact.go
index cc307e2..8ce7e96 100644
--- a/sdks/go/cmd/beamctl/cmd/artifact.go
+++ b/sdks/go/cmd/beamctl/cmd/artifact.go
@@ -19,7 +19,7 @@ import (
        "path/filepath"
 
        "github.com/apache/beam/sdks/go/pkg/beam/artifact"
-       pb "github.com/apache/beam/sdks/go/pkg/beam/model/jobmanagement_v1"
+       jobpb "github.com/apache/beam/sdks/go/pkg/beam/model/jobmanagement_v1"
        "github.com/spf13/cobra"
 )
 
@@ -67,7 +67,7 @@ func stageFn(cmd *cobra.Command, args []string) error {
 
        // (2) Stage files in parallel, commit and print out token
 
-       client := pb.NewLegacyArtifactStagingServiceClient(cc)
+       client := jobpb.NewLegacyArtifactStagingServiceClient(cc)
        list, err := artifact.MultiStage(ctx, client, 10, files, stagingToken)
        if err != nil {
                return err
@@ -88,8 +88,8 @@ func listFn(cmd *cobra.Command, args []string) error {
        }
        defer cc.Close()
 
-       client := pb.NewLegacyArtifactRetrievalServiceClient(cc)
-       md, err := client.GetManifest(ctx, &pb.GetManifestRequest{})
+       client := jobpb.NewLegacyArtifactRetrievalServiceClient(cc)
+       md, err := client.GetManifest(ctx, &jobpb.GetManifestRequest{})
        if err != nil {
                return err
        }