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

commit ba565e95b4d11e3de1af08381919728826cc574c
Author: Chamikara Jayalath <chamikar...@gmail.com>
AuthorDate: Fri Mar 8 20:52:59 2024 -0800

    updates
---
 .../launcher/TransformServiceLauncher.java         | 38 ++++++++++++----------
 1 file changed, 20 insertions(+), 18 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 c0028b53afe..b0c5976d29c 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
@@ -127,12 +127,17 @@ public class TransformServiceLauncher {
       }
     }
 
+    LOG.error("TransformServiceLauncher constructor: 1");
+
     // Setting up the dependencies directory.
     File dependenciesDir = Paths.get(tmpDir, "dependencies_dir").toFile();
     Path updatedRequirementsFilePath = Paths.get(dependenciesDir.toString(), 
"requirements.txt");
     if (dependenciesDir.exists()) {
-      throw new RuntimeException(
-          "xyz123 Dependencies dir " + dependenciesDir.toString() + " 
exists.");
+      LOG.error("TransformServiceLauncher constructor: 2");
+      LOG.error(
+          "TransformServiceLauncher constructor: Dependencies dir "
+              + dependenciesDir.toString()
+              + " exists.");
       // LOG.info("Reusing the existing dependencies directory " +
       // dependenciesDir.getAbsolutePath());
     } else {
@@ -153,11 +158,13 @@ public class TransformServiceLauncher {
             "Could not create the new requirements file " + 
updatedRequirementsFilePath);
       }
 
-      boolean pythonRequirementsFileNull = true;
+      LOG.error(
+          "TransformServiceLauncher constructor: Created  
updatedRequirementsFilePath: "
+              + updatedRequirementsFilePath);
 
       // Updating dependencies.
       if (pythonRequirementsFile != null) {
-        pythonRequirementsFileNull = false;
+        LOG.error("TransformServiceLauncher constructor: 3");
         Path requirementsFilePath = Paths.get(pythonRequirementsFile);
         List<String> updatedLines = new ArrayList<>();
 
@@ -194,16 +201,13 @@ public class TransformServiceLauncher {
           }
           writer.flush();
         }
-      }
 
-      boolean b = true;
-      if (b) {
-        throw new RuntimeException(
-            "******* xyz123 requirements file name: "
-                + file.getAbsolutePath()
-                + " pythonRequirementsFileNull: "
-                + pythonRequirementsFileNull);
+        LOG.error("TransformServiceLauncher constructor: wrote to new 
requirements file");
+      } else {
+        LOG.error("TransformServiceLauncher constructor: 4");
       }
+
+      LOG.error("TransformServiceLauncher constructor: 5");
     }
 
     // Setting environment variables used by the docker-compose.yml file.
@@ -369,12 +373,7 @@ public class TransformServiceLauncher {
 
   public static void main(String[] args) throws IOException, TimeoutException {
 
-    LOG.error("launching the service 1");
-
-    boolean b = true;
-    if (b) {
-      throw new RuntimeException("******* xyz123 launching the service");
-    }
+    LOG.error("TransformServiceLauncher: launching the service 1");
 
     ArgConfig config = new ArgConfig();
     CmdLineParser parser = new CmdLineParser(config);
@@ -414,6 +413,9 @@ public class TransformServiceLauncher {
     String pythonRequirementsFile =
         !config.pythonRequirementsFile.isEmpty() ? 
config.pythonRequirementsFile : null;
 
+    LOG.error(
+        "TransformServiceLauncher: pythonRequirementsFile at main: " + 
pythonRequirementsFile);
+
     TransformServiceLauncher service =
         TransformServiceLauncher.forProject(
             config.projectName, config.port, pythonRequirementsFile);