Log error when marking queue job for outgoing message complete fails

nyaruka · Nov 1, 2024 · 5886459 · 5886459
1 parent 1eb6259
commit 5886459
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/backends/rapidpro/backend.go b/backends/rapidpro/backend.go
@@ -466,7 +466,10 @@ func (b *backend) MarkOutgoingMsgComplete(ctx context.Context, msg courier.MsgOu
 
 	dbMsg := msg.(*Msg)
 
-	queue.MarkComplete(rc, msgQueueName, dbMsg.workerToken)
+	err := queue.MarkComplete(rc, msgQueueName, dbMsg.workerToken)
+	if err != nil {
+		slog.Error("error marking outgoing message complete", "error", err, "msg_id", dbMsg.ID_.String(), "status", status.Status())
+	}
 
 	// mark as sent in redis as well if this was actually wired or sent
 	if status != nil && (status.Status() == courier.MsgStatusSent || status.Status() == courier.MsgStatusWired) {