diff --git a/services/web/app/src/Features/InactiveData/InactiveProjectManager.js b/services/web/app/src/Features/InactiveData/InactiveProjectManager.js index 93f9866f60..01fef41aaa 100644 --- a/services/web/app/src/Features/InactiveData/InactiveProjectManager.js +++ b/services/web/app/src/Features/InactiveData/InactiveProjectManager.js @@ -72,6 +72,7 @@ module.exports = InactiveProjectManager = { .select('_id') .sort({ _id: 1 }) .limit(limit) + .read('secondary') .exec(function(err, projects) { if (err != null) { logger.err({ err }, 'could not get projects for deactivating') diff --git a/services/web/app/src/Features/Project/ProjectDeleter.js b/services/web/app/src/Features/Project/ProjectDeleter.js index 4ba7c59b4d..c502299c24 100644 --- a/services/web/app/src/Features/Project/ProjectDeleter.js +++ b/services/web/app/src/Features/Project/ProjectDeleter.js @@ -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