diff --git a/src/repositories/baseRepository.js b/src/repositories/baseRepository.js index ffa8a8485..7bf77d434 100644 --- a/src/repositories/baseRepository.js +++ b/src/repositories/baseRepository.js @@ -16,7 +16,8 @@ class BaseRepository { } async aggregatePaginate (aggregation, options) { - const arg = this.collection.aggregate(aggregation) + const readPref = options.readPreference ? options.readPreference : '' + const arg = this.collection.aggregate(aggregation).read(readPref) return this.collection.aggregatePaginate(arg, options) }