perf(ebooks): feed configured backfill workers
This commit is contained in:
@@ -17,7 +17,7 @@ const (
|
||||
maxEnrichmentRetry = 24 * time.Hour
|
||||
transientRetryBase = 5 * time.Minute
|
||||
skippedRetryHorizon = 15 * time.Minute
|
||||
claimCandidateWindow = 64
|
||||
claimCandidateWindow = maxEnrichWorkers
|
||||
)
|
||||
|
||||
type EnrichmentOutcome string
|
||||
|
||||
@@ -87,8 +87,8 @@ func TestEnrichmentQueueClaimQueryUsesAtomicLeasedClaims(t *testing.T) {
|
||||
}
|
||||
})
|
||||
}
|
||||
if claimCandidateWindow <= 0 || claimCandidateWindow > 256 {
|
||||
t.Fatalf("claim candidate window = %d, want a fixed sane bound", claimCandidateWindow)
|
||||
if claimCandidateWindow != maxEnrichWorkers {
|
||||
t.Fatalf("claim candidate window = %d, want worker ceiling %d", claimCandidateWindow, maxEnrichWorkers)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user