damccorm commented on code in PR #28107:
URL: https://github.com/apache/beam/pull/28107#discussion_r1303151576
##########
sdks/python/container/boot.go:
##########
@@ -380,26 +380,26 @@ func installSetupPackages(files []string, workDir string,
requirementsFiles []st
pkgName := "apache-beam"
isSdkInstalled := isPackageInstalled(pkgName)
if !isSdkInstalled {
- return fmt.Errorf("Apache Beam is not installed in the runtime
environment. If you use a custom container image, you must install apache-beam
package in the custom image using same version of Beam as in the pipeline
submission environment. For more information, see: the
https://beam.apache.org/documentation/runtime/environments/.";)
+ return fmt.Errorf("apache-beam is not installed in the runtime
environment. If you use a custom container image, you must install apache-beam
package in the custom image using same version of Beam as in the pipeline
submission environment. For more information, see: the
https://beam.apache.org/documentation/runtime/environments/";)
}
// Install the Dataflow Python SDK and worker packages.
// We install the extra requirements in case of using the beam sdk.
These are ignored by pip
// if the user is using an SDK that does not provide these.
if err := installSdk(files, workDir, sdkSrcFile, acceptableWhlSpecs,
false); err != nil {
- return fmt.Errorf("failed to install SDK: %v", err)
+ return fmt.Errorf("failed to install SDK (this may be
unrecoverable): %v", err)
Review Comment:
It can be super brief
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
