File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1435,7 +1435,7 @@ EnsembleContext::ScheduleSteps(
14351435 for (auto & step : steps) {
14361436 step->ctx_ = context;
14371437 size_t this_step_idx = step->step_idx_ ;
1438-
1438+
14391439 // Block if this step is overloaded.
14401440 if (context->info_ ->max_inflight_responses_ > 0 &&
14411441 !context->step_cv_vec_ .empty ()) {
@@ -1447,8 +1447,8 @@ EnsembleContext::ScheduleSteps(
14471447 return (req == nullptr ) || req->IsCancelled ();
14481448 };
14491449
1450- bool capacity_available = context-> step_cv_vec_ [this_step_idx]-> wait_for (
1451- lk, timeout, [&] {
1450+ bool capacity_available =
1451+ context-> step_cv_vec_ [this_step_idx]-> wait_for ( lk, timeout, [&] {
14521452 return cancelled () ||
14531453 (context->step_inflight_response_counts_ [this_step_idx] <
14541454 context->info_ ->max_inflight_responses_ );
You can’t perform that action at this time.
0 commit comments