metrics.PollSuccessPerTaskQueueCounter.With(tm.metricsHandler).Record(1)
return task, false, nil
}
// From here on the goroutine will block on taskC (in step 3 or 4), so it
// is ready to receive a sync-matched task.
defer tm.waitingPollerCount.Add(-1)
if tm.isBacklogNegligible() {
// 3. forwarding (and all other clauses repeated)
// We don't forward pollers if there is a non-negligible backlog in this partition.