diff --git a/src/system/process.py b/src/system/process.py index 832a0928bd..0dbeb05a31 100644 --- 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 index 7b4efb9bba..128b0577d0 100644 --- 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)