From 32d25f76fc0b91a15c6ddf730e7b138373e59b7f Mon Sep 17 00:00:00 2001 From: ius Date: Thu, 12 Mar 2026 17:44:57 +0800 Subject: [PATCH] fix: respect preconfigured usage log batch channels --- backend/internal/repository/usage_log_repo.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/internal/repository/usage_log_repo.go b/backend/internal/repository/usage_log_repo.go index 53ca7d11..5a022665 100644 --- a/backend/internal/repository/usage_log_repo.go +++ b/backend/internal/repository/usage_log_repo.go @@ -377,7 +377,7 @@ func (r *usageLogRepository) createBatched(ctx context.Context, log *service.Usa } func (r *usageLogRepository) ensureCreateBatcher() { - if r == nil || r.db == nil { + if r == nil || r.db == nil || r.createBatchCh != nil { return } r.createBatchOnce.Do(func() { @@ -387,7 +387,7 @@ func (r *usageLogRepository) ensureCreateBatcher() { } func (r *usageLogRepository) ensureBestEffortBatcher() { - if r == nil || r.db == nil { + if r == nil || r.db == nil || r.bestEffortBatchCh != nil { return } r.bestEffortBatchOnce.Do(func() {