indexer_scheduler teak

bluesky-social · Dec 17, 2024 · 460999a · 460999a
1 parent 62ddc08
commit 460999a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/indexer/crawler.go b/indexer/crawler.go
@@ -146,11 +146,11 @@ func (c *CrawlDispatcher) mainLoop() {
 			limiter := c.repoFetcher.GetOrCreateLimiterLazy(pdsID)
 			now := time.Now()
 			avail := limiter.TokensAt(now)
-			if avail > 1 {
+			if avail >= 1.0 {
 				crawlJob.eligibleTime = now
 			} else {
 				rate := float64(limiter.Limit())
-				need := 1 - avail
+				need := 1.0 - avail
 				wouldDelay := time.Duration(float64(time.Second) * need / rate)
 				crawlJob.eligibleTime = now.Add(wouldDelay)
 			}