Skip to content

Commit

Permalink
Fix REJECTED Error counters
Browse files Browse the repository at this point in the history
  • Loading branch information
indrajit96 committed Jul 10, 2024
1 parent fdf1a44 commit acb2d3f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/dynamic_batch_scheduler.cc
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ IsStaleState(Payload::State payload_state)
void
FinishSkippedRequests(
std::vector<std::deque<std::unique_ptr<InferenceRequest>>>&& requests,
const Status& response_status)
const Status& response_status, FailureReason reason)
{
for (auto& queue : requests) {
for (auto& request : queue) {
Expand All @@ -71,8 +71,8 @@ FinishRejectedCancelledRequests(
const static Status rejected_status =
Status(Status::Code::UNAVAILABLE, "Request timeout expired");
const static Status cancelled_status = Status(Status::Code::CANCELLED);
FinishSkippedRequests(std::move(rejected_requests), rejected_status);
FinishSkippedRequests(std::move(cancelled_requests), cancelled_status);
FinishSkippedRequests(std::move(rejected_requests), rejected_status, FailureReason::REJECTED);
FinishSkippedRequests(std::move(cancelled_requests), cancelled_status, FailureReason::CANCELED);
}

DynamicBatchScheduler::DynamicBatchScheduler(
Expand Down

0 comments on commit acb2d3f

Please sign in to comment.