File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -441,7 +441,7 @@ def __call__(
441
441
442
442
def compile (
443
443
self , state : AggregatorState , scheduler_state : SchedulerState
444
- ) -> dict [Literal ["scheduler_stats " ], BenchmarkSchedulerStats ]:
444
+ ) -> dict [Literal ["run_stats " ], BenchmarkSchedulerStats ]:
445
445
"""
446
446
Compile scheduler timing metrics into benchmark statistics.
447
447
@@ -473,7 +473,7 @@ def compile(
473
473
key = "worker_resolve_time" , type_ = "avg" , default = 0.0
474
474
),
475
475
worker_resolve_end_delay_avg = state .get_metric (
476
- key = "worker_resolve_end_delay" , type_ = "avg"
476
+ key = "worker_resolve_end_delay" , type_ = "avg" , default = 0.0
477
477
),
478
478
finalized_delay_avg = state .get_metric (
479
479
key = "finalized_delay" , type_ = "avg" , default = 0.0
Original file line number Diff line number Diff line change @@ -680,6 +680,8 @@ def next_strategy(
680
680
self .throughput_rate = (
681
681
prev_benchmark .metrics .requests_per_second .successful .mean
682
682
)
683
+ if self .synchronous_rate <= 0 and self .throughput_rate <= 0 :
684
+ raise RuntimeError ("Invalid rates in sweep; aborting. Where there any successful requests?" )
683
685
self .measured_rates = list (
684
686
np .linspace (
685
687
self .synchronous_rate ,
@@ -698,7 +700,6 @@ def next_strategy(
698
700
if strat .type_ == self .strategy_type
699
701
]
700
702
)
701
-
702
703
if self .strategy_type == "constant" :
703
704
return AsyncConstantStrategy (
704
705
rate = self .measured_rates [next_rate_index ],
You can’t perform that action at this time.
0 commit comments