From fd662721bb8c536f00901d485f563c7882bc3452 Mon Sep 17 00:00:00 2001 From: Eli Ribble Date: Fri, 17 Apr 2026 18:19:13 +0000 Subject: [PATCH] Fix non-rolled-back transactions --- platform/start.go | 1 + 1 file changed, 1 insertion(+) diff --git a/platform/start.go b/platform/start.go index 112ef912..83698d70 100644 --- a/platform/start.go +++ b/platform/start.go @@ -90,6 +90,7 @@ func addWaitingJobs(ctx context.Context) error { log.Error().Err(err).Msg("failed begin txn") return } + defer txn.Rollback(ctx) err = handleJob(ctx, txn, job) if err != nil { log.Error().Err(err).Msg("failed handle job")