From f884f0809f0d30bd090cd33eff9e16d8ac6238cc Mon Sep 17 00:00:00 2001 From: Abhishek Pandey Date: Tue, 10 Oct 2023 03:22:33 +0530 Subject: [PATCH] Remove per minute count --- src/internal/m365/graph/concurrency_middleware.go | 2 -- src/internal/stats/stats.go | 4 ---- 2 files changed, 6 deletions(-) diff --git a/src/internal/m365/graph/concurrency_middleware.go b/src/internal/m365/graph/concurrency_middleware.go index d93bd2246..c470fc1cf 100644 --- a/src/internal/m365/graph/concurrency_middleware.go +++ b/src/internal/m365/graph/concurrency_middleware.go @@ -191,8 +191,6 @@ func QueueRequest(ctx context.Context) { if err := limiter.WaitN(ctx, consume); err != nil { logger.CtxErr(ctx, err).Error("graph middleware waiting on the limiter") } - - // Add to the count bus } // RateLimiterMiddleware is used to ensure we don't overstep per-min request limits. diff --git a/src/internal/stats/stats.go b/src/internal/stats/stats.go index bd790dc9f..187984d31 100644 --- a/src/internal/stats/stats.go +++ b/src/internal/stats/stats.go @@ -48,9 +48,6 @@ type SkippedCounts struct { type APIStats struct { TokensConsumed int64 `json:"tokensConsumed"` - // PeakTokenUsage is the maximum number of tokens used during a - // rolling 1 minute window. - PeakTokenUsagePerMin int64 `json:"peakTokenUsage"` } func GetAPIStats( @@ -59,7 +56,6 @@ func GetAPIStats( s := APIStats{} s.TokensConsumed = ctr.Total(count.APICallTokensConsumed) - s.PeakTokenUsagePerMin = ctr.Get(count.PeakAPITokenUsagePerMin) return s }