|
|
@ -413,7 +413,7 @@ func (sl *scrapeLoop) run(interval, timeout time.Duration, errc chan<- error) { |
|
|
|
if !sl.appender.NeedsThrottling() { |
|
|
|
if !sl.appender.NeedsThrottling() { |
|
|
|
var ( |
|
|
|
var ( |
|
|
|
start = time.Now() |
|
|
|
start = time.Now() |
|
|
|
scrapeCtx, _ = context.WithTimeout(sl.ctx, timeout) |
|
|
|
scrapeCtx, cancel = context.WithTimeout(sl.ctx, timeout) |
|
|
|
numPostRelabelSamples = 0 |
|
|
|
numPostRelabelSamples = 0 |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
@ -425,6 +425,7 @@ func (sl *scrapeLoop) run(interval, timeout time.Duration, errc chan<- error) { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
samples, err := sl.scraper.scrape(scrapeCtx, start) |
|
|
|
samples, err := sl.scraper.scrape(scrapeCtx, start) |
|
|
|
|
|
|
|
cancel() |
|
|
|
if err == nil { |
|
|
|
if err == nil { |
|
|
|
numPostRelabelSamples, err = sl.append(samples) |
|
|
|
numPostRelabelSamples, err = sl.append(samples) |
|
|
|
} |
|
|
|
} |
|
|
|