diff --git a/internal/worker/concurrency_auto_scaler.go b/internal/worker/concurrency_auto_scaler.go index c9cce9960..5cc8a62ce 100644 --- a/internal/worker/concurrency_auto_scaler.go +++ b/internal/worker/concurrency_auto_scaler.go @@ -216,11 +216,13 @@ func (c *ConcurrencyAutoScaler) logEvent(event autoScalerEvent) { } c.scope.Histogram(metricsPollerQuota, metricsPollerQuotaBuckets).RecordValue(float64(c.concurrency.PollerPermit.Quota())) c.scope.Histogram(metricsPollerWaitTime, metricsPollerWaitTimeBuckets).RecordDuration(c.pollerWaitTime.Average()) - c.log.Debug(autoScalerEventLogMsg, - zap.String("event", string(event)), - zap.Bool("enabled", c.enabled), - zap.Int("poller_quota", c.concurrency.PollerPermit.Quota()), - ) + if event != autoScalerEventEmitMetrics { + c.log.Debug(autoScalerEventLogMsg, + zap.String("event", string(event)), + zap.Bool("enabled", c.enabled), + zap.Int("poller_quota", c.concurrency.PollerPermit.Quota()), + ) + } } func (c *ConcurrencyAutoScaler) updatePollerPermit() { diff --git a/internal/worker/concurrency_auto_scaler_test.go b/internal/worker/concurrency_auto_scaler_test.go index 9298c053d..592ef707e 100644 --- a/internal/worker/concurrency_auto_scaler_test.go +++ b/internal/worker/concurrency_auto_scaler_test.go @@ -301,15 +301,13 @@ func TestConcurrencyAutoScaler(t *testing.T) { var actualEvents []eventLog for _, event := range obs.FilterMessage(autoScalerEventLogMsg).All() { - if event.ContextMap()["event"] != string(autoScalerEventEmitMetrics) { - t.Log("event: ", event.ContextMap()) + t.Log("event: ", event.ContextMap()) - actualEvents = append(actualEvents, eventLog{ - eventType: autoScalerEvent(event.ContextMap()["event"].(string)), - enabled: event.ContextMap()["enabled"].(bool), - pollerQuota: event.ContextMap()["poller_quota"].(int64), - }) - } + actualEvents = append(actualEvents, eventLog{ + eventType: autoScalerEvent(event.ContextMap()["event"].(string)), + enabled: event.ContextMap()["enabled"].(bool), + pollerQuota: event.ContextMap()["poller_quota"].(int64), + }) } assert.ElementsMatch(t, tt.expectedEvents, actualEvents) })