We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 94185f3 commit defc47bCopy full SHA for defc47b
internal/internal_worker_base.go
@@ -332,7 +332,7 @@ func (bw *baseWorker) pollTask() {
332
bw.retrier.Failed()
333
} else {
334
bw.retrier.Succeeded()
335
- if t, ok :=task.(autoConfigHintAwareTask); bw.concurrencyAutoScaler != nil && ok {
+ if t, ok := task.(autoConfigHintAwareTask); bw.concurrencyAutoScaler != nil && ok {
336
bw.concurrencyAutoScaler.ProcessPollerHint(t.getAutoConfigHint())
337
}
338
0 commit comments