added logs to warn about repair of old events

retracedhq · Jun 16, 2023 · 2289431 · 2289431
1 parent dd11fc3
commit 2289431
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/_processor/workers/NormalizeRepairer.ts b/src/_processor/workers/NormalizeRepairer.ts
@@ -47,10 +47,13 @@ export default class NormalizeRepairer {
   }
 
   public async repairOldEvents() {
+    logger.warn(`Looking for jobs older than ${this.minAgeMs}ms missing 'normalized_event'`);
     const resp = await this.pgPool.query(NormalizeRepairer.selectFromIngestTask, [
       this.minAgeMs,
       this.maxEvents,
     ]);
+    logger.warn(`Found ${resp.rows.length} jobs older than ${this.minAgeMs}ms missing 'normalized_event'`);
+
     if (!resp.rows.length) {
       logger.debug(`No jobs older than ${this.minAgeMs}ms missing 'normalized_event'`);
       incrementOtelCounter("NormalizeRepairer.repairOldEvents.allClear");