This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a commit to branch transform_service_test_suite
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/transform_service_test_suite
by this push:
new 768030e7863 updates
768030e7863 is described below
commit 768030e78637c2e1a3dbaac233fbaed1ab25f855
Author: Chamikara Jayalath <[email protected]>
AuthorDate: Fri Feb 16 15:59:40 2024 -0800
updates
---
sdks/python/expansion-service-container/boot.go | 17 ++++++++++++-----
1 file changed, 12 insertions(+), 5 deletions(-)
diff --git a/sdks/python/expansion-service-container/boot.go
b/sdks/python/expansion-service-container/boot.go
index 23b88d8f699..5f2bd617580 100644
--- a/sdks/python/expansion-service-container/boot.go
+++ b/sdks/python/expansion-service-container/boot.go
@@ -24,6 +24,7 @@ import (
"io/ioutil"
"log"
"os"
+// "os/exec"
"path/filepath"
"strconv"
"strings"
@@ -145,11 +146,17 @@ func launchExpansionServiceProcess() error {
args := []string{"-m", expansionServiceEntrypoint, "-p",
strconv.Itoa(*port), "--fully_qualified_name_glob", "*"}
- log.Printf("****** xyz123 executing ls -al")
- if err := execx.Execute("ls", "-al", "/dependencies_volume/"); err !=
nil {
- return fmt.Errorf("Could not execute ls -al")
- }
- log.Printf("****** xyz123 DONE executing ls -al")
+
+ log.Printf("****** xyz123 executing ls -al:")
+ if err := execx.Execute("/bin/ls", "-al"); err != nil {
+ log.Printf("could not execute the ls command: %s", err)
+ }
+
+ log.Printf("****** xyz123 executing ls -al /:")
+ if err := execx.Execute("/bin/ls", "-al", "/"); err != nil {
+ log.Printf("could not execute the ls command: %s", err)
+ }
+
if *requirements_file != "" {
log.Printf("Received the requirements file %v",
*requirements_file)
