diff options
author | Johannes Gäßler <johannesg@5d6.de> | 2024-05-15 08:44:16 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-05-15 08:44:16 +0200 |
commit | 583fd6b000ec9ad1b465b5c98524f4a0ae388077 (patch) | |
tree | 9458889a19a8c5da1ead80793a20450218ecb95d /examples/server | |
parent | 9f773486ab78d65f5cca3f7e31c862b7043bf721 (diff) |
server bench: fix bench not waiting for model load (#7284)
Diffstat (limited to 'examples/server')
-rw-r--r-- | examples/server/bench/bench.py | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/examples/server/bench/bench.py b/examples/server/bench/bench.py index 86c5de10..25ac29c4 100644 --- a/examples/server/bench/bench.py +++ b/examples/server/bench/bench.py @@ -293,13 +293,14 @@ def start_server_background(args): def is_server_listening(server_fqdn, server_port): - with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as sock: - result = sock.connect_ex((server_fqdn, server_port)) - _is_server_listening = result == 0 - if _is_server_listening: - print(f"server is listening on {server_fqdn}:{server_port}...") - return _is_server_listening - + try: + url = f"{server_fqdn}:{server_port}/health" + if not url.startswith("http://"): + url = f"http://{url}" + result = requests.get(url) + return result.status_code == 200 + except Exception: + return False def escape_metric_name(metric_name): return re.sub('[^A-Z0-9]', '_', metric_name.upper()) |