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 28dc3294f44f..590c9392a991 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 629ede0f9527..3fd6edd37e32 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" )