log list of bundles to retry

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

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/src/database/sql/bundles/repair.sql b/src/database/sql/bundles/repair.sql
@@ -22,7 +22,6 @@ FROM (
   ORDER BY b.import_attempt_count, b.last_queued_at ASC
   LIMIT @limit
 )
-ORDER BY RANDOM()
 
 -- updateFullyIndexedAt
 UPDATE bundles

diff --git a/src/database/standalone-sqlite.ts b/src/database/standalone-sqlite.ts
@@ -812,14 +812,16 @@ export class StandaloneSqliteDatabaseWorker {
   getFailedBundleIds(limit: number) {
     const reprocessCutoff = currentUnixTimestamp() - BUNDLE_REPROCESS_WAIT_SECS;
 
+    const rows = this.stmts.bundles.selectFailedBundleIds.all({
+      limit,
+      reprocess_cutoff: reprocessCutoff,
+    });
+
     this.log.debug('getFailedBundleIds', {
       reprocessCutoff,
       BUNDLE_REPROCESS_WAIT_SECS,
-    });
-
-    const rows = this.stmts.bundles.selectFailedBundleIds.all({
       limit,
-      reprocess_cutoff: reprocessCutoff,
+      rowsLength: rows.length,
     });
 
     return rows.map((row): string => toB64Url(row.id));

diff --git a/src/workers/bundle-repair-worker.ts b/src/workers/bundle-repair-worker.ts
@@ -107,6 +107,7 @@ export class BundleRepairWorker {
       );
 
       this.log.debug('Bundles to retry', {
+        idsLength: bundleIds.length,
         bundleIds,
         batchSize: config.BUNDLE_REPAIR_RETRY_BATCH_SIZE,
       });