diff --git a/run.sh b/run.sh index 0829d44d9f..640672e698 100755 --- a/run.sh +++ b/run.sh @@ -20,5 +20,5 @@ echo "Installing dependencies in $DIR ..." export PIPENV_PIPFILE="$DIR/Pipfile" python3 -m pipenv install -echo "Running "$1" ${@:2} ..." +if [[ ! "$1" == *benchmark* ]]; then (echo "Running "$1" ${@:2} ..."; ); fi python3 -m pipenv run python "$1" ${@:2} diff --git a/src/test_workflow/benchmark_test/benchmark_test_cluster.py b/src/test_workflow/benchmark_test/benchmark_test_cluster.py index 916c27558e..ed822c74dd 100644 --- a/src/test_workflow/benchmark_test/benchmark_test_cluster.py +++ b/src/test_workflow/benchmark_test/benchmark_test_cluster.py @@ -32,7 +32,7 @@ def __init__( self.args = args self.cluster_endpoint = self.args.cluster_endpoint self.cluster_endpoint_with_port = None - self.password = None + self.password = self.args.password def start(self) -> None: @@ -40,7 +40,7 @@ def start(self) -> None: try: result = subprocess.run(command, shell=True, capture_output=True, timeout=5) except subprocess.TimeoutExpired: - raise TimeoutError(f"Time out! Couldn't connect to the cluster {self.cluster_endpoint}") + raise TimeoutError(f"Time out! Couldn't connect to the cluster") if result.stdout: res_dict = json.loads(result.stdout) @@ -65,10 +65,10 @@ def fetch_password(self) -> str: return self.password def wait_for_processing(self, tries: int = 3, delay: int = 15, backoff: int = 2) -> None: - logging.info(f"Waiting for domain at {self.endpoint} to be up") + logging.info(f"Waiting for domain ******* to be up") protocol = "http://" if self.args.insecure else "https://" url = "".join([protocol, self.endpoint, "/_cluster/health"]) - self.password = None if self.args.insecure else get_password(self.args.distribution_version) + # self.password = None if self.args.insecure else get_password(self.args.distribution_version) request_args = {"url": url} if self.args.insecure else {"url": url, "auth": HTTPBasicAuth(self.args.username, self.args.password), # type: ignore "verify": False} # type: ignore retry_call(requests.get, fkwargs=request_args, tries=tries, delay=delay, backoff=backoff) diff --git a/test.sh b/test.sh index c4a266cb13..3352e35a48 100755 --- a/test.sh +++ b/test.sh @@ -21,7 +21,6 @@ case $1 in "$DIR/run.sh" "$DIR/src/run_perf_test.py" "${@:2}" ;; "benchmark-test") - echo "the parameters passed are ${@:2}" "$DIR/run.sh" "$DIR/src/run_benchmark_test.py" "${@:2}" ;; *)