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 402c8449c96 updates
402c8449c96 is described below
commit 402c8449c96bb214830f663f1b88ab78d6b90009
Author: Chamikara Jayalath <[email protected]>
AuthorDate: Sat Mar 9 16:41:18 2024 -0800
updates
---
sdks/python/expansion-service-container/boot.go | 51 +++++++++++++------------
1 file changed, 26 insertions(+), 25 deletions(-)
diff --git a/sdks/python/expansion-service-container/boot.go
b/sdks/python/expansion-service-container/boot.go
index 983541d6bf3..5d73e0a34b7 100644
--- a/sdks/python/expansion-service-container/boot.go
+++ b/sdks/python/expansion-service-container/boot.go
@@ -157,31 +157,32 @@ func launchExpansionServiceProcess() error {
return fmt.Errorf("Could not execute /usr/bin/ls -al /: %s",
err)
}
-// 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 {
-// 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
-// }
-// } else if (*requirements_file) {
-// log.Printf("Requirements file %s was provided but not available.",
*requirements_file)
-// }
+ requirement_file_exists := false
+ if _, err := os.Stat(*requirements_file); err == nil {
+ requirement_file_exists = true
+ }
+
+ log.Printf("boot.go requirement_file_exists: %v", requirement_file_exists)
+
+ if requirement_file_exists {
+ log.Printf("boot.go 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
+ }
+ } else {
+ 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)
