Merge pull request #123 from formancehq/fix/atlar-retries

fix(atlar): retry in case of error when updating tf status
formancehq · Oct 14, 2024 · bd40e5e · bd40e5e
2 parents a849e77 + e5ca6b1
commit bd40e5e
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)