fix(atlar): add retry when updating payment status

formancehq · Oct 14, 2024 · e5ca6b1 · e5ca6b1
1 parent a849e77
commit e5ca6b1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cmd/connectors/internal/connectors/atlar/task_payments.go b/cmd/connectors/internal/connectors/atlar/task_payments.go
@@ -199,7 +199,7 @@ func UpdatePaymentStatusTask(
 		)
 		if err != nil {
 			otel.RecordError(span, err)
-			return err
+			return fmt.Errorf("failed to get atlar transfer: %w, %w", err, task.ErrRetryable)
 		}
 
 		status := getCreditTransferResponse.Payload.Status
@@ -370,7 +370,7 @@ func ingestAtlarTransaction(
 	transactionResponse, err := client.GetV1TransactionsID(requestCtx, transactionId)
 	if err != nil {
 		otel.RecordError(span, err)
-		return err
+		return fmt.Errorf("failed to get atlar transactions: %w, %w", err, task.ErrRetryable)
 	}
 
 	batchElement, err := atlarTransactionToPaymentBatchElement(ctx, connectorID, taskID, transactionResponse.Payload, client)