Update

Signed-off-by: Zelin Hao <zelinhao@amazon.com>
zelinh · Jul 18, 2023 · e9bdc4d · e9bdc4d
1 parent 85b492c
commit e9bdc4d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/system/process.py b/src/system/process.py
@@ -61,6 +61,7 @@ def terminate(self) -> int:
             self.stdout.seek(0)
             self.__stdout_data__ = self.stdout.read()
             self.stdout.close()
+            self.stdout.flush()
             # for proc in psutil.process_iter():
             #     try:
             #         for item in proc.open_files():
@@ -70,6 +71,7 @@ def terminate(self) -> int:
             #     except Exception:
             #         pass
             os.remove(self.stdout.name)
+            #os.unlink(self.stdout.name)
             self.stdout = None
 
         if self.stderr:

diff --git a/src/test_workflow/integ_test/integ_test_suite_opensearch_dashboards.py b/src/test_workflow/integ_test/integ_test_suite_opensearch_dashboards.py
@@ -110,7 +110,7 @@ def custom_node_endpoint_encoder(node_endpoint: NodeEndpoint) -> dict:
             return {"endpoint": node_endpoint.endpoint, "port": node_endpoint.port, "transport": node_endpoint.transport}
         if os.path.exists(script):
             single_node = cluster_endpoints[0].data_nodes[0]
-            cmd = f"bash {script} -b {single_node.endpoint} -p {single_node.port} -s {str(security).lower()} -t {self.component.name} -v {self.bundle_manifest.build.version} -o default"
+            cmd = f"bash {script} -b {single_node.endpoint} -p {single_node.port} -s {str(security).lower()} -t {self.component.name} -v {self.bundle_manifest.build.version} -o default | tee /tmp/1234"
             self.repo_work_dir = os.path.join(
                 self.repo.dir, self.test_config.working_directory) if self.test_config.working_directory is not None else self.repo.dir
             (status, stdout, stderr) = execute(cmd, self.repo_work_dir, True, False)