diff --git a/lib/logstorage/storage_search.go b/lib/logstorage/storage_search.go
index ea2d5a8ab..c728d9998 100644
--- a/lib/logstorage/storage_search.go
+++ b/lib/logstorage/storage_search.go
@@ -409,7 +409,9 @@ func (p *part) searchByTenantIDs(so *searchOptions, bhss *blockHeaders, workCh c
 				if so.minTimestamp > th.maxTimestamp || so.maxTimestamp < th.minTimestamp {
 					continue
 				}
-				scheduleBlockSearch(bh)
+				if !scheduleBlockSearch(bh) {
+					return
+				}
 			}
 			if len(bhs) == 0 {
 				break