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() {