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 415d5705163 updates
415d5705163 is described below
commit 415d57051634a3a89b669a8a722c3aeb863f004d
Author: Chamikara Jayalath <[email protected]>
AuthorDate: Tue Mar 5 21:54:24 2024 -0800
updates
---
.../runners/portability/expansion_service_main.py | 14 ++++++++++++++
1 file changed, 14 insertions(+)
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 307f6bd5418..1b4cc17e0c5 100644
--- a/sdks/python/apache_beam/runners/portability/expansion_service_main.py
+++ b/sdks/python/apache_beam/runners/portability/expansion_service_main.py
@@ -39,6 +39,20 @@ _LOGGER = logging.getLogger(__name__)
def main(argv):
+
+ import os
+
+ path = "/"
+ dir_list = os.listdir(path)
+ print("******** xyz123 Files and directories in '", path, "' :")
+ print(dir_list)
+
+ path = "/dependencies_volume/"
+ dir_list = os.listdir(path)
+ print("******** xyz123 Files and directories in '", path, "' :")
+ print(dir_list)
+
+
parser = argparse.ArgumentParser()
parser.add_argument(
'-p', '--port', type=int, help='port on which to serve the job api')
