(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 7f2ca952127 updates
7f2ca952127 is described below

commit 7f2ca9521278e63180af4177fc87b76f800bab5a
Author: Chamikara Jayalath <chamikar...@gmail.com>
AuthorDate: Wed Mar 6 00:01:54 2024 -0800

    updates
---
 .../transformservice/launcher/TransformServiceLauncher.java   |  3 ++-
 .../apache_beam/runners/portability/expansion_service_main.py |  2 +-
 sdks/python/expansion-service-container/boot.go               | 11 ++++++++++-
 3 files changed, 13 insertions(+), 3 deletions(-)

diff --git 
a/sdks/java/transform-service/launcher/src/main/java/org/apache/beam/sdk/transformservice/launcher/TransformServiceLauncher.java
 
b/sdks/java/transform-service/launcher/src/main/java/org/apache/beam/sdk/transformservice/launcher/TransformServiceLauncher.java
index c0a9097a762..a61cfc4ffce 100644
--- 
a/sdks/java/transform-service/launcher/src/main/java/org/apache/beam/sdk/transformservice/launcher/TransformServiceLauncher.java
+++ 
b/sdks/java/transform-service/launcher/src/main/java/org/apache/beam/sdk/transformservice/launcher/TransformServiceLauncher.java
@@ -131,7 +131,8 @@ public class TransformServiceLauncher {
     File dependenciesDir = Paths.get(tmpDir, "dependencies_dir").toFile();
     Path updatedRequirementsFilePath = Paths.get(dependenciesDir.toString(), 
"requirements.txt");
     if (dependenciesDir.exists()) {
-      LOG.info("Reusing the existing dependencies directory " + 
dependenciesDir.getAbsolutePath());
+      throw new RuntimeException("xyz123 Dependencies dir " + 
dependenciesDir.toString() + " exists.");
+      // LOG.info("Reusing the existing dependencies directory " + 
dependenciesDir.getAbsolutePath());
     } else {
       LOG.info(
           "Creating a temporary directory for storing dependencies: "
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 063e4406e65..5dcd1429cbe 100644
--- a/sdks/python/apache_beam/runners/portability/expansion_service_main.py
+++ b/sdks/python/apache_beam/runners/portability/expansion_service_main.py
@@ -55,7 +55,7 @@ def main(argv):
   print(dir_list)
   print2 = "******** xyz123 Files and directories in '" + path + "' :" + 
str(dir_list)
 
-  raise Exception(print1 + "    " + print2)
+#   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 22a228381ba..983541d6bf3 100644
--- a/sdks/python/expansion-service-container/boot.go
+++ b/sdks/python/expansion-service-container/boot.go
@@ -157,7 +157,13 @@ func launchExpansionServiceProcess() error {
                return fmt.Errorf("Could not execute /usr/bin/ls -al /: %s", 
err)
        }
 
-//     if *requirements_file != "" {
+//   if _, err := os.Stat(*requirements_file); errors.Is(err, os.ErrNotExist) {
+//     requirement_file_exists = false
+//   } else {
+//     requirement_file_exists = true
+//   }
+//
+//     if requirement_file_exists {
 //             log.Printf("Received the requirements file %v", 
*requirements_file)
 //             updatedRequirementsFileName, err := 
getUpdatedRequirementsFile(*requirements_file, *dependencies_dir)
 //             if err != nil {
@@ -173,7 +179,10 @@ func launchExpansionServiceProcess() error {
 //             if err != nil {
 //                     return err
 //             }
+//     } else if (*requirements_file) {
+//       log.Printf("Requirements file %s was provided but not available.", 
*requirements_file)
 //     }
+
        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)