File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -481,6 +481,9 @@ class EnsembleContext {
481481 // better distinguish ensemble ending behavior (see annotation in
482482 // FinishEnsemble for details).
483483 bool response_sent_{false };
484+
485+ // Prevents duplicate error responses or status annotation when FinishEnsemble
486+ // is invoked multiple times while steps are still in-flight.
484487 bool error_response_sent_{false };
485488
486489 // The allocator that will be used to allocate buffers for the
@@ -1555,9 +1558,8 @@ EnsembleContext::ScheduleSteps(
15551558 } else {
15561559 std::lock_guard<std::mutex> lock (context->mutex_ );
15571560 context->ensemble_status_ = step_status;
1558- LOG_VERBOSE (1 ) << " Ensemble '" << context->info_ ->ensemble_name_
1559- << " ' failed to schedule step : "
1560- << step_status.Message ();
1561+ LOG_WARNING << " Ensemble '" << context->info_ ->ensemble_name_
1562+ << " ' failed to schedule step : " << step_status.Message ();
15611563 }
15621564 }
15631565
You can’t perform that action at this time.
0 commit comments