(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 d5f80704027 Updates
d5f80704027 is described below

commit d5f80704027d9af867a6c8209646f4630b0c493b
Author: Chamikara Jayalath <chamikar...@gmail.com>
AuthorDate: Tue Mar 5 18:12:26 2024 -0800

    Updates
---
 sdks/python/expansion-service-container/boot.go | 34 ++++++++++++-------------
 1 file changed, 17 insertions(+), 17 deletions(-)

diff --git a/sdks/python/expansion-service-container/boot.go 
b/sdks/python/expansion-service-container/boot.go
index 3c6636fd846..2e9b1eff6eb 100644
--- a/sdks/python/expansion-service-container/boot.go
+++ b/sdks/python/expansion-service-container/boot.go
@@ -157,23 +157,23 @@ func launchExpansionServiceProcess() error {
                return fmt.Errorf("Could not execute /usr/bin/ls -al /: %s", 
err)
        }
 
-       if *requirements_file != "" {
-               log.Printf("Received the requirements file %v", 
*requirements_file)
-               updatedRequirementsFileName, err := 
getUpdatedRequirementsFile(*requirements_file, *dependencies_dir)
-               if err != nil {
-                       return err
-               }
-               defer os.Remove(updatedRequirementsFileName)
-               log.Printf("Updated requirements file is %v", 
updatedRequirementsFileName)
-               // Provide the requirements file to the expansion service so 
that packages get staged by runners.
-               args = append(args, "--requirements_file", 
updatedRequirementsFileName)
-               // Install packages locally so that they can be used by the 
expansion service during transform
-               // expansion if needed.
-               err = installExtraPackages(updatedRequirementsFileName)
-               if err != nil {
-                       return err
-               }
-       }
+//     if *requirements_file != "" {
+//             log.Printf("Received the requirements file %v", 
*requirements_file)
+//             updatedRequirementsFileName, err := 
getUpdatedRequirementsFile(*requirements_file, *dependencies_dir)
+//             if err != nil {
+//                     return err
+//             }
+//             defer os.Remove(updatedRequirementsFileName)
+//             log.Printf("Updated requirements file is %v", 
updatedRequirementsFileName)
+//             // Provide the requirements file to the expansion service so 
that packages get staged by runners.
+//             args = append(args, "--requirements_file", 
updatedRequirementsFileName)
+//             // Install packages locally so that they can be used by the 
expansion service during transform
+//             // expansion if needed.
+//             err = installExtraPackages(updatedRequirementsFileName)
+//             if err != nil {
+//                     return err
+//             }
+//     }
        if err := execx.Execute(pythonVersion, args...); err != nil {
                return fmt.Errorf("could not start the expansion service: %s", 
err)
        }