Minor: name pipeline_v1 import to match rest of SDK. (#14775)
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 @@
"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 @@
}
// Put schema and row into payload proto, and marshal it.
- ecp := &pipeline_v1.ExternalConfigurationPayload{
+ ecp := &pipepb.ExternalConfigurationPayload{
Schema: scm,
Payload: buf.Bytes(),
}