Clean up.

artie-labs · Aug 20, 2024 · ee7f6cb · ee7f6cb
1 parent a1f1146
commit ee7f6cb
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/processes/consumer/flush.go b/processes/consumer/flush.go
@@ -81,9 +81,6 @@ func Flush(ctx context.Context, inMemDB *models.DatabaseData, dest destination.B
 			}
 
 			start := time.Now()
-			err = retry.WithRetries(retryCfg, func(_ int, _ error) error {
-				return flush(ctx, dest, _tableName, _tableData)
-			})
 
 			tags := map[string]string{
 				"what":     "success",
@@ -94,6 +91,10 @@ func Flush(ctx context.Context, inMemDB *models.DatabaseData, dest destination.B
 				"reason":   args.Reason,
 			}
 
+			err = retry.WithRetries(retryCfg, func(_ int, _ error) error {
+				return flush(ctx, dest, _tableName, _tableData)
+			})
+
 			if err != nil {
 				tags["what"] = "merge_fail"
 				slog.Error(fmt.Sprintf("Failed to %s", action), slog.Any("err", err), slog.String("tableName", _tableName))