log list of bundles to retry

ar-io · Jan 14, 2025 · 165021e · 165021e
1 parent 997f375
commit 165021e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/src/config.ts b/src/config.ts
@@ -263,7 +263,7 @@ export const BUNDLE_REPAIR_RETRY_INTERVAL_SECONDS = +env.varOrDefault(
 );
 
 export const BUNDLE_REPAIR_RETRY_BATCH_SIZE = +env.varOrDefault(
-  'BUNDLE_REPAIR_RETRY_INTERVAL_SECONDS',
+  'BUNDLE_REPAIR_RETRY_BATCH_SIZE',
   '1000',
 );
 

diff --git a/src/database/standalone-sqlite.ts b/src/database/standalone-sqlite.ts
@@ -810,9 +810,16 @@ export class StandaloneSqliteDatabaseWorker {
   }
 
   getFailedBundleIds(limit: number) {
+    const reprocessCutoff = currentUnixTimestamp() - BUNDLE_REPROCESS_WAIT_SECS;
+
+    this.log.debug('getFailedBundleIds', {
+      reprocessCutoff,
+      BUNDLE_REPROCESS_WAIT_SECS,
+    });
+
     const rows = this.stmts.bundles.selectFailedBundleIds.all({
       limit,
-      reprocess_cutoff: currentUnixTimestamp() - BUNDLE_REPROCESS_WAIT_SECS,
+      reprocess_cutoff: reprocessCutoff,
     });
 
     return rows.map((row): string => toB64Url(row.id));
-Original file line number
+Diff line change
@@ Expand Up @@
     );
     export const BUNDLE_REPAIR_RETRY_BATCH_SIZE = +env.varOrDefault(
-      'BUNDLE_REPAIR_RETRY_INTERVAL_SECONDS',
+      'BUNDLE_REPAIR_RETRY_BATCH_SIZE',
       '1000',
     );
@@ Expand Down @@