chore: record incremental scrape from event lag

flanksource · Feb 4, 2025 · f29a7b9 · f29a7b9
1 parent b889201
commit f29a7b9
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/scrapers/event.go b/scrapers/event.go
@@ -80,7 +80,7 @@ func incrementalScrapeFromEvent(ctx context.Context, event models.Event) error {
 		return fmt.Errorf("failed to get config (%s): %w", configID, err)
 	}
 
-	if config.DeletedAt != nil || time.Since(lo.FromPtr(config.LastScrapedTime)) <= time.Second*30 {
+	if config.DeletedAt != nil {
 		// assume the health is upto-date
 		return nil
 	}
@@ -128,5 +128,8 @@ func incrementalScrapeFromEvent(ctx context.Context, event models.Event) error {
 		}
 	}
 
+	ctx.Histogram("incremental_scrape_event", involvedObjectsFetchBuckets, "scraper_id", lo.FromPtr(config.ScraperID), "type", lo.FromPtr(config.Type)).
+		Record(time.Duration(time.Since(event.CreatedAt).Milliseconds()))
+
 	return nil
 }