From 213de4c55b89f543c00b177ed485b419fdb199a6 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Mon, 19 Aug 2024 18:45:48 -0700 Subject: [PATCH] Tweak retries. --- 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 f1f0ed1a4..cba027b66 100644 --- a/processes/consumer/flush.go +++ b/processes/consumer/flush.go @@ -67,7 +67,7 @@ func Flush(ctx context.Context, inMemDB *models.DatabaseData, dest destination.B action = "append" } - retryCfg, err := retry.NewJitterRetryConfig(250, 15_000, 5, retry.AlwaysRetry) + retryCfg, err := retry.NewJitterRetryConfig(500, 30_000, 10, retry.AlwaysRetry) if err != nil { slog.Error("Failed to create retry config", slog.Any("err", err)) return