Skip to content

Commit

Permalink
fix missing error return in mysql deleter
Browse files Browse the repository at this point in the history
  • Loading branch information
jessepeterson committed Aug 28, 2023
1 parent 65daeb8 commit 6d0d00b
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions storage/mysql/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -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, `
Expand Down

0 comments on commit 6d0d00b

Please sign in to comment.