1movmedia/pyworker
2
0
Fork 0
Code Pull Requests Activity

catch the case where all benchmarks fail (sets error)

Browse Source
This commit is contained in:
Colter Downing
2025-10-27 12:01:55 -07:00
parent bcecd6df40
commit d6eb498ee4
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/backend.py
+3
View File
@@ -350,6 +350,9 @@ class Backend:
total_workload = sum(br.workload for br in benchmark_requests if br.is_successful) total_workload = sum(br.workload for br in benchmark_requests if br.is_successful)
time_elapsed = time.time() - start time_elapsed = time.time() - start
successful_responses = sum([1 for br in benchmark_requests if br.is_successful]) successful_responses = sum([1 for br in benchmark_requests if br.is_successful])
if successful_responses == 0:
self.backend_errored("No successful responses from benchmark")
log.debug(f"benchmark failed: {successful_responses}/{concurrent_requests} successful responses")
throughput = total_workload / time_elapsed throughput = total_workload / time_elapsed
sum_throughput += throughput sum_throughput += throughput
lib/data_types.py
+1 -1
View File
@@ -257,7 +257,7 @@ class ModelMetrics:
def wait_time(self) -> float: def wait_time(self) -> float:
if (len(self.requests_working) == 0): if (len(self.requests_working) == 0):
return 0.0 return 0.0
return sum([request.workload for request in self.requests_working.values()]) / self.max_throughput return sum([request.workload for request in self.requests_working.values()]) / max(self.max_throughput, 0.00001)
@property @property
def cur_load(self) -> float: def cur_load(self) -> float: