This is an automated email from the ASF dual-hosted git repository. lostluck pushed a commit to branch lostluck-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 39d929840521f9c7f3ec605ca94524fd0776bf6e Author: Robert Burke <[email protected]> AuthorDate: Mon May 10 15:53:59 2021 -0700 Minor: name pipeline_v1 import to match rest of SDK. --- sdks/go/pkg/beam/core/runtime/xlangx/payload.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/go/pkg/beam/core/runtime/xlangx/payload.go b/sdks/go/pkg/beam/core/runtime/xlangx/payload.go index c038463..cdb3457 100644 --- a/sdks/go/pkg/beam/core/runtime/xlangx/payload.go +++ b/sdks/go/pkg/beam/core/runtime/xlangx/payload.go @@ -19,10 +19,10 @@ import ( "bytes" "reflect" + pipepb "github.com/apache/beam/sdks/go/pkg/beam/model/pipeline_v1" "github.com/apache/beam/sdks/go/pkg/beam/core/graph/coder" "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx/schema" "github.com/apache/beam/sdks/go/pkg/beam/internal/errors" - "github.com/apache/beam/sdks/go/pkg/beam/model/pipeline_v1" "google.golang.org/protobuf/proto" ) @@ -53,7 +53,7 @@ func EncodeStructPayload(pl interface{}) ([]byte, error) { } // Put schema and row into payload proto, and marshal it. - ecp := &pipeline_v1.ExternalConfigurationPayload{ + ecp := &pipepb.ExternalConfigurationPayload{ Schema: scm, Payload: buf.Bytes(), }
