From 6d0d00b9228285b6e9d30dac28026078d4f0568a Mon Sep 17 00:00:00 2001 From: Jesse Peterson Date: Mon, 28 Aug 2023 15:20:18 -0700 Subject: [PATCH] fix missing error return in mysql deleter --- storage/mysql/queue.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/storage/mysql/queue.go b/storage/mysql/queue.go index 2a0be58..7c1ef83 100644 --- a/storage/mysql/queue.go +++ b/storage/mysql/queue.go @@ -56,6 +56,9 @@ SELECT command_uuid FROM commands WHERE command_uuid = ? FOR UPDATE; `, uuid, ) + if err != nil { + return err + } // delete command result (i.e. NotNows) and this queued command _, err = tx.ExecContext( ctx, `