From 668acb9566cceea3b8838453f5c1d2a8d2923b67 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Mon, 7 Oct 2024 10:35:54 -0700 Subject: [PATCH] Tweaking retries (#952) --- processes/consumer/flush.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/processes/consumer/flush.go b/processes/consumer/flush.go index 61e08cb9f..ca40b7068 100644 --- a/processes/consumer/flush.go +++ b/processes/consumer/flush.go @@ -62,7 +62,7 @@ func Flush(ctx context.Context, inMemDB *models.DatabaseData, dest destination.B return } - retryCfg, err := retry.NewJitterRetryConfig(500, 30_000, 10, retry.AlwaysRetry) + retryCfg, err := retry.NewJitterRetryConfig(1_000, 30_000, 15, retry.AlwaysRetry) if err != nil { slog.Error("Failed to create retry config", slog.Any("err", err)) return