(beam) branch transform_service_test_suite updated: Updates

[chamikara]

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 8f2c1979fad Updates
8f2c1979fad is described below

commit 8f2c1979fad361ff4c2934e8055723bb16916a4a
Author: Chamikara Jayalath <chamikar...@gmail.com>
AuthorDate: Tue Mar 5 22:23:47 2024 -0800

    Updates
---
 sdks/python/apache_beam/runners/portability/expansion_service_main.py | 4 ++++
 sdks/python/expansion-service-container/boot.go                       | 3 ++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/sdks/python/apache_beam/runners/portability/expansion_service_main.py 
b/sdks/python/apache_beam/runners/portability/expansion_service_main.py
index 1b4cc17e0c5..294258ba355 100644
--- a/sdks/python/apache_beam/runners/portability/expansion_service_main.py
+++ b/sdks/python/apache_beam/runners/portability/expansion_service_main.py
@@ -47,11 +47,15 @@ def main(argv):
   print("******** xyz123 Files and directories in '", path, "' :")
   print(dir_list)
 
+  print1 = "******** xyz123 Files and directories in '", path, "' :" + 
str(dir_list)
+
   path = "/dependencies_volume/"
   dir_list = os.listdir(path)
   print("******** xyz123 Files and directories in '", path, "' :")
   print(dir_list)
+  print2 = "******** xyz123 Files and directories in '", path, "' :" + 
str(dir_list)
 
+  raise Exception(print1 + "    " + print2)
 
   parser = argparse.ArgumentParser()
   parser.add_argument(
diff --git a/sdks/python/expansion-service-container/boot.go 
b/sdks/python/expansion-service-container/boot.go
index 2e9b1eff6eb..22a228381ba 100644
--- a/sdks/python/expansion-service-container/boot.go
+++ b/sdks/python/expansion-service-container/boot.go
@@ -138,7 +138,7 @@ func launchExpansionServiceProcess() error {
        if err != nil {
                return err
        }
-       log.Printf("Starting Python expansion service ... 1")
+       log.Printf("Starting Python expansion service ... 2")
 
        dir := filepath.Join("/opt/apache/beam", venvDirectory)
        os.Setenv("VIRTUAL_ENV", dir)
@@ -175,6 +175,7 @@ func launchExpansionServiceProcess() error {
 //             }
 //     }
        if err := execx.Execute(pythonVersion, args...); err != nil {
+         log.Printf("****** xyz123 could not start the expansion service: %s", 
err)
                return fmt.Errorf("could not start the expansion service: %s", 
err)
        }