fix(atlar): retry in case of error when updating tf status

formancehq · Oct 11, 2024 · 1b83c07 · 1b83c07
1 parent a849e77
commit 1b83c07
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/cmd/connectors/internal/connectors/atlar/task_payments.go b/cmd/connectors/internal/connectors/atlar/task_payments.go
@@ -188,7 +188,7 @@ func UpdatePaymentStatusTask(
 		transfer, err := getTransfer(ctx, storageReader, transferInitiationID, true)
 		if err != nil {
 			otel.RecordError(span, err)
-			return err
+			return fmt.Errorf("failed to get transfer: %v, %w", err, task.ErrRetryable)
 		}
 
 		requestCtx, cancel := contextutil.DetachedWithTimeout(ctx, 30*time.Second)
@@ -199,7 +199,7 @@ func UpdatePaymentStatusTask(
 		)
 		if err != nil {
 			otel.RecordError(span, err)
-			return err
+			return fmt.Errorf("failed to get atlar transfer: %v, %w", err, task.ErrRetryable)
 		}
 
 		status := getCreditTransferResponse.Payload.Status
@@ -215,7 +215,7 @@ func UpdatePaymentStatusTask(
 			})
 			if err != nil {
 				otel.RecordError(span, err)
-				return err
+				return fmt.Errorf("failed to create next task: %v, %w", err, task.ErrRetryable)
 			}
 
 			err = scheduler.Schedule(ctx, taskDescriptor, models.TaskSchedulerOptions{
@@ -225,7 +225,7 @@ func UpdatePaymentStatusTask(
 			})
 			if err != nil && !errors.Is(err, task.ErrAlreadyScheduled) {
 				otel.RecordError(span, err)
-				return err
+				return fmt.Errorf("failed to schedule next task: %v, %w", err, task.ErrRetryable)
 			}
 			return nil
 
@@ -239,7 +239,7 @@ func UpdatePaymentStatusTask(
 			)
 			if err != nil {
 				otel.RecordError(span, err)
-				return err
+				return fmt.Errorf("failed to create next task: %v, %w", err, task.ErrRetryable)
 			}
 
 			paymentID = &models.PaymentID{
@@ -253,7 +253,7 @@ func UpdatePaymentStatusTask(
 			err = ingester.UpdateTransferInitiationPayment(ctx, transfer, paymentID, models.TransferInitiationStatusProcessed, "", time.Now())
 			if err != nil {
 				otel.RecordError(span, err)
-				return err
+				return fmt.Errorf("failed to update transfer initiation payment: %v, %w", err, task.ErrRetryable)
 			}
 
 			return nil
@@ -265,7 +265,7 @@ func UpdatePaymentStatusTask(
 			)
 			if err != nil {
 				otel.RecordError(span, err)
-				return err
+				return fmt.Errorf("failed to update transfer initiation payment: %v, %w", err, task.ErrRetryable)
 			}
 
 			return nil