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 ccbd1c53aec updates
ccbd1c53aec is described below
commit ccbd1c53aec9bc28ec6bc143385b383d8a377828
Author: Chamikara Jayalath <[email protected]>
AuthorDate: Fri Feb 16 12:20:26 2024 -0800
updates
---
sdks/python/expansion-service-container/boot.go | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
diff --git a/sdks/python/expansion-service-container/boot.go
b/sdks/python/expansion-service-container/boot.go
index 1119d50339e..23b88d8f699 100644
--- a/sdks/python/expansion-service-container/boot.go
+++ b/sdks/python/expansion-service-container/boot.go
@@ -137,7 +137,7 @@ func launchExpansionServiceProcess() error {
if err != nil {
return err
}
- log.Printf("Starting Python expansion service ...")
+ log.Printf("Starting Python expansion service ... 1")
dir := filepath.Join("/opt/apache/beam", venvDirectory)
os.Setenv("VIRTUAL_ENV", dir)
@@ -145,15 +145,19 @@ 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")
+
if *requirements_file != "" {
log.Printf("Received the requirements file %v",
*requirements_file)
updatedRequirementsFileName, err :=
getUpdatedRequirementsFile(*requirements_file, *dependencies_dir)
if err != nil {
return err
}
- if err := execx.Execute("ls", "-al", "/dependencies_volume/");
err != nil {
- return fmt.Errorf("Could not execute ls -al")
- }
+
defer os.Remove(updatedRequirementsFileName)
log.Printf("Updated requirements file is %v",
updatedRequirementsFileName)
