Skip to content

Commit

Permalink
Include error in log if message checkpoint sending fails
Browse files Browse the repository at this point in the history
  • Loading branch information
tulir committed Sep 11, 2023
1 parent b2a54de commit eea14cb
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion bridge/messagecheckpoint.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ func (br *Bridge) SendMessageCheckpoint(evt *event.Event, step status.MessageChe
func (br *Bridge) SendRawMessageCheckpoint(cp *status.MessageCheckpoint) {
err := br.SendMessageCheckpoints([]*status.MessageCheckpoint{cp})
if err != nil {
br.ZLog.Warn().Interface("message_checkpoint", cp).Msg("Error sending message checkpoint")
br.ZLog.Warn().Err(err).Interface("message_checkpoint", cp).Msg("Error sending message checkpoint")
} else {
br.ZLog.Debug().Interface("message_checkpoint", cp).Msg("Sent message checkpoint")
}
Expand Down

0 comments on commit eea14cb

Please sign in to comment.