chore(plugin): add extra logs for SQS errors

sedaprotocol · Jan 15, 2025 · be6b3a5 · be6b3a5
1 parent c2937a1
commit be6b3a5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/plugins/indexing/pluginaws/sqs_client.go b/plugins/indexing/pluginaws/sqs_client.go
@@ -63,6 +63,9 @@ func (sc *SqsClient) sendMessageBatch(batch []*sqs.SendMessageBatchRequestEntry)
 	sc.logger.Trace("send batch request succeeded")
 
 	if len(result.Failed) > 0 {
+		for _, failed := range result.Failed {
+			sc.logger.Error("failed to send message", "error", failed.Message, "id", failed.Id, "code", failed.Code, "senderFault", failed.SenderFault)
+		}
 		return fmt.Errorf("failed to send %d messages", len(result.Failed))
 	}