fix(plugins): use context-aware database execution in TaskQueue host service

Signed-off-by: Deluan <deluan@navidrome.org>
This commit is contained in:
Deluan 2026-02-26 18:49:14 -05:00 committed by Deluan Quintão
parent 2d5de23c6d
commit 86bae9831c

View File

@ -527,7 +527,7 @@ func (s *taskQueueServiceImpl) runCleanup() {
now := time.Now().UnixMilli()
for name, qs := range queues {
result, err := s.db.Exec(`
result, err := s.db.ExecContext(s.ctx, `
DELETE FROM tasks WHERE queue_name = ? AND status IN (?, ?, ?) AND updated_at + ? < ?
`, name, taskStatusCompleted, taskStatusFailed, taskStatusCancelled, qs.config.RetentionMs, now)
if err != nil {