in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/AbstractConcurrencyLoadBalancer.java [163:170]
public void complete(boolean succeed, Duration latency) {
if (!succeed) {
//if task failed, postpone counter for (timeout - latency)
scheduledCounter.schedule(1, timeout.minus(latency));
} else {
super.complete(true, latency);
}
}