fix(migration): log out dropped ids after stream end

opencrvs · Oct 8, 2024 · fea0749 · fea0749
1 parent c44afb0
commit fea0749
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/packages/search/src/features/reindex/reindex.ts b/packages/search/src/features/reindex/reindex.ts
@@ -62,6 +62,8 @@ export const reindex = async () => {
  }
  })
 
+ const droppedCompositionIds: string[] = []
+
  await client.helpers.bulk(
  {
  retries: 3,
@@ -74,20 +76,26 @@ export const reindex = async () => {
  }
  }),
  onDrop(doc) {
- console.log('dropping id', doc.document.compositionId)
+ droppedCompositionIds.push(doc.document.compositionId)
  }
  },
  {
  meta: true
  }
  )
+
  const t2 = performance.now()
  logger.info(
  `Finished reindexing to ${index} in ${((t2 - t1) / 1000).toFixed(
  2
  )} seconds`
  )
 
+ if (droppedCompositionIds.length) {
+ logger.warn(`Could not index ${droppedCompositionIds.length} document(s)`)
+ logger.warn(droppedCompositionIds.join(', '))
+ }
+
  return { index }
 }