|
|
@@ -89,7 +89,9 @@ async function expireDeletedProjectsAfterDuration() {
|
|
|
project: { $ne: null }
|
|
|
},
|
|
|
{ 'deleterData.deletedProjectId': 1 }
|
|
|
- ).limit(PROJECT_EXPIRATION_BATCH_SIZE)
|
|
|
+ )
|
|
|
+ .limit(PROJECT_EXPIRATION_BATCH_SIZE)
|
|
|
+ .read('secondary')
|
|
|
const projectIds = _.shuffle(
|
|
|
deletedProjects.map(
|
|
|
deletedProject => deletedProject.deleterData.deletedProjectId
|