Obey the max pending maintenance operations.

1 files changed, 1 insertions, 1 deletions

diff --git a/searchcore/src/vespa/searchcore/proton/server/pruneremoveddocumentsjob_v2.cpp b/searchcore/src/vespa/searchcore/proton/server/pruneremoveddocumentsjob_v2.cpp
index 0c5b165611e..7bfdaf678b7 100644
--- a/searchcore/src/vespa/searchcore/proton/server/pruneremoveddocumentsjob_v2.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/pruneremoveddocumentsjob_v2.cpp
@@ -94,7 +94,7 @@ PruneRemovedDocumentsJobV2::run()
                              (vespalib::count_us(now.time_since_epoch() - _cfgAgeLimit)));
     const DocId docIdLimit(_metaStore.getCommittedDocIdLimit());
     const DocId lidLimit = std::min(_nextLid + 1000000u, docIdLimit);
-    for (uint32_t removed = 0; removed < 1000 && _nextLid < lidLimit; _nextLid++) {
+    for (; ! isBlocked() && _nextLid < lidLimit; _nextLid++) {
         if ( ! _metaStore.validLid(_nextLid)) continue;
         const RawDocumentMetaData &meta = _metaStore.getRawMetaData(_nextLid);
         if (meta.getTimestamp() >= ageLimit) continue;