From 37adec320eab9aef6cfe316ca67616262f6687e2 Mon Sep 17 00:00:00 2001 From: rxwatcher Date: Mon, 20 Jul 2026 07:48:13 +0200 Subject: [PATCH] perf(ebooks): feed configured backfill workers --- internal/ebooks/enrichment_queue.go | 2 +- internal/ebooks/enrichment_queue_test.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/ebooks/enrichment_queue.go b/internal/ebooks/enrichment_queue.go index f2c5d850..b3aca11e 100644 --- a/internal/ebooks/enrichment_queue.go +++ b/internal/ebooks/enrichment_queue.go @@ -17,7 +17,7 @@ const ( maxEnrichmentRetry = 24 * time.Hour transientRetryBase = 5 * time.Minute skippedRetryHorizon = 15 * time.Minute - claimCandidateWindow = 64 + claimCandidateWindow = maxEnrichWorkers ) type EnrichmentOutcome string diff --git a/internal/ebooks/enrichment_queue_test.go b/internal/ebooks/enrichment_queue_test.go index ac169441..72f5d4e9 100644 --- a/internal/ebooks/enrichment_queue_test.go +++ b/internal/ebooks/enrichment_queue_test.go @@ -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) } }