You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bh...@apache.org on 2022/10/20 21:59:58 UTC

[beam] branch master updated: fix lints

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 <ri...@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"
 )