Skip to content

Commit f96ec8d

Browse files
committed
add progress bar
1 parent f38e4e0 commit f96ec8d

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

tests/performance/locustfiles/functions/map_test_sleeper.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import osparc_client
2222
from httpx import BasicAuth, Client, HTTPStatusError
2323
from tenacity import retry, retry_if_exception_type, stop_after_delay, wait_exponential
24+
from tqdm import tqdm
2425

2526
_SOLVER_KEY = "simcore/services/comp/itis/sleeper"
2627
_SOLVER_VERSION = "2.2.1"
@@ -110,7 +111,9 @@ def main(njobs: int, sleep_seconds: int, log_job: bool = False):
110111
job = job_api_instance.get_function_job(function_job_ids[0])
111112
print_job_logs(configuration, job.actual_instance.solver_job_id)
112113

113-
for job_uid in function_job_ids:
114+
for job_uid in tqdm(
115+
function_job_ids, desc="Waiting for jobs to complete", unit="job"
116+
):
114117
status = wait_until_done(job_api_instance, job_uid)
115118
job_statuses[status] = job_statuses.get(status, 0) + 1
116119

0 commit comments

Comments
 (0)