From 86bae9831c3fac0aa83b01d603866f5f757905d1 Mon Sep 17 00:00:00 2001 From: Deluan Date: Thu, 26 Feb 2026 18:49:14 -0500 Subject: [PATCH] fix(plugins): use context-aware database execution in TaskQueue host service Signed-off-by: Deluan --- plugins/host_taskqueue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/host_taskqueue.go b/plugins/host_taskqueue.go index 59be317db..ec68de6d8 100644 --- a/plugins/host_taskqueue.go +++ b/plugins/host_taskqueue.go @@ -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 {