This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 3e8bc10c767 fix lints
new 3d055da2fce Merge pull request #23759 from riteshghorse/import-fix
3e8bc10c767 is described below
commit 3e8bc10c7678e99ef480398cd939f3cb48e0c631
Author: riteshghorse <riteshgho...@gmail.com>
AuthorDate: Thu Oct 20 13:42:52 2022 -0400
fix lints
---
sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go | 2 +-
sdks/go/pkg/beam/transforms/xlang/python/external.go | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go
b/sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go
index 28dc3294f44..590c9392a99 100644
--- a/sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go
+++ b/sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go
@@ -58,7 +58,7 @@ func NewExpansionServiceRunner(jarPath, servicePort string)
(*ExpansionServiceRu
return &ExpansionServiceRunner{execPath: jarPath, servicePort:
servicePort, serviceCommand: serviceCommand}, nil
}
-// NewExpansionServiceRunner builds an ExpansionServiceRunner struct for a
given python module and
+// NewPyExpansionServiceRunner builds an ExpansionServiceRunner struct for a
given python module and
// Beam version and returns a pointer to it. Passing an empty string as
servicePort will request an
// open port to be assigned to the service.
func NewPyExpansionServiceRunner(pythonExec, module, servicePort string)
(*ExpansionServiceRunner, error) {
diff --git a/sdks/go/pkg/beam/transforms/xlang/python/external.go
b/sdks/go/pkg/beam/transforms/xlang/python/external.go
index 629ede0f952..3fd6edd37e3 100644
--- a/sdks/go/pkg/beam/transforms/xlang/python/external.go
+++ b/sdks/go/pkg/beam/transforms/xlang/python/external.go
@@ -27,7 +27,8 @@ import (
)
const (
- pythonCallableUrn = "beam:logical_type:python_callable:v1"
+ pythonCallableUrn = "beam:logical_type:python_callable:v1"
+ // ExpansionServiceModule is the module containing the python expansion
service for python external transforms.
ExpansionServiceModule =
"apache_beam.runners.portability.expansion_service_main"
)
