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")