Skip to content

Commit 8db6fa9

Browse files
committed
log poller hint information
1 parent 6b9605b commit 8db6fa9

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

internal/worker/concurrency_auto_scaler.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -183,6 +183,10 @@ func (c *ConcurrencyAutoScaler) ProcessPollerHint(hint *shared.AutoConfigHint) {
183183
c.lock.Lock()
184184
defer c.lock.Unlock()
185185

186+
if hint.PollerWaitTimeInMs == nil || *hint.PollerWaitTimeInMs == 0 {
187+
c.log.Debug("poller wait time hint", zap.Int64("wait_time_in_ms", *hint.PollerWaitTimeInMs))
188+
}
189+
186190
if hint.PollerWaitTimeInMs != nil && *hint.PollerWaitTimeInMs >= 0 {
187191
waitTimeInMs := *hint.PollerWaitTimeInMs
188192
c.pollerWaitTime.Add(time.Millisecond * time.Duration(waitTimeInMs))

0 commit comments

Comments
 (0)