Skip to content

Commit cc983de

Browse files
committed
fix: don't index soft-deleted records
1 parent 837bc3e commit cc983de

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

src/common/helper.js

+9-1
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,15 @@ async function indexBulkDataToES (modelName, indexName, logger) {
230230
// get data from db
231231
logger.info({ component: 'indexBulkDataToES', message: 'Getting data from database' })
232232
const model = models[modelName]
233-
const data = await model.findAll({ raw: true })
233+
const data = await model.findAll({
234+
where: {
235+
deletedAt: null
236+
},
237+
raw: true,
238+
attributes: {
239+
exclude: ['deletedAt']
240+
},
241+
})
234242
if (_.isEmpty(data)) {
235243
logger.info({ component: 'indexBulkDataToES', message: `No data in database for ${modelName}` })
236244
return

0 commit comments

Comments
 (0)