diff --git a/src/test_workflow/integ_test/integ_test_suite_opensearch.py b/src/test_workflow/integ_test/integ_test_suite_opensearch.py index c06be71384..dfbf2bd7da 100644 --- a/src/test_workflow/integ_test/integ_test_suite_opensearch.py +++ b/src/test_workflow/integ_test/integ_test_suite_opensearch.py @@ -109,7 +109,7 @@ def custom_node_endpoint_encoder(node_endpoint: NodeEndpoint) -> dict: if os.path.exists(script): if len(cluster_endpoints) == 1: single_data_node = cluster_endpoints[0].data_nodes[0] - cmd = f"bash {script} -b {single_data_node.endpoint} -p {single_data_node.port} -s {str(security).lower()} -v {self.bundle_manifest.build.version} | tee /tmp/123" + cmd = f"bash {script} -b {single_data_node.endpoint} -p {single_data_node.port} -s {str(security).lower()} -v {self.bundle_manifest.build.version}" else: endpoints_list = [] for cluster_details in cluster_endpoints: 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 d3a0cff8da..4deb6941b9 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 | tee /tmp/123" + 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" 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)