Skip to content

Commit

Permalink
Remove unnecessary pass of logger
Browse files Browse the repository at this point in the history
Signed-off-by: Paschalis Tsilias <paschalis.tsilias@grafana.com>
  • Loading branch information
tpaschalis committed Jan 5, 2024
1 parent 4e01348 commit 0af7806
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions storage/remote/queue_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -591,7 +591,7 @@ func isSampleOld(baseTime time.Time, sampleAgeLimit time.Duration, ts int64) boo
return sampleTs.Before(limitTs)
}

func isTimeSeriesOldFilter(metrics *queueManagerMetrics, logger log.Logger, baseTime time.Time, sampleAgeLimit time.Duration) func(ts prompb.TimeSeries) bool {
func isTimeSeriesOldFilter(metrics *queueManagerMetrics, baseTime time.Time, sampleAgeLimit time.Duration) func(ts prompb.TimeSeries) bool {
return func(ts prompb.TimeSeries) bool {
if sampleAgeLimit == 0 {
// If sampleAgeLimit is unset, then we never skip samples due to their age.
Expand Down Expand Up @@ -1587,7 +1587,7 @@ func (s *shards) sendSamplesWithBackoff(ctx context.Context, samples []prompb.Ti
nil,
pBuf,
*buf,
isTimeSeriesOldFilter(s.qm.metrics, s.qm.logger, currentTime, time.Duration(s.qm.cfg.SampleAgeLimit)),
isTimeSeriesOldFilter(s.qm.metrics, currentTime, time.Duration(s.qm.cfg.SampleAgeLimit)),
)
s.qm.buildRequestLimitTimestamp.Store(lowest)
if err != nil {
Expand Down

0 comments on commit 0af7806

Please sign in to comment.