From 0973b193d46275c59ed172d6c723366954e95fcb Mon Sep 17 00:00:00 2001 From: Pierre Mesure Date: Tue, 28 Apr 2026 11:25:12 +0200 Subject: [PATCH] Increase max_retries to 10 --- lib/sequin/sinks/meilisearch/client.ex | 2 +- test/sequin/meilisearch_client_test.exs | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/sequin/sinks/meilisearch/client.ex b/lib/sequin/sinks/meilisearch/client.ex index 26effd614..a75bb6ef3 100644 --- a/lib/sequin/sinks/meilisearch/client.ex +++ b/lib/sequin/sinks/meilisearch/client.ex @@ -27,7 +27,7 @@ defmodule Sequin.Sinks.Meilisearch.Client do url: "/tasks/#{task_id}", # We need to disable this if we use a custom retry that emits delays retry_delay: nil, - max_retries: 5, + max_retries: 10, retry: fn request, response_or_exception -> should_retry = case response_or_exception do diff --git a/test/sequin/meilisearch_client_test.exs b/test/sequin/meilisearch_client_test.exs index d6441c692..bc3d0770f 100644 --- a/test/sequin/meilisearch_client_test.exs +++ b/test/sequin/meilisearch_client_test.exs @@ -339,12 +339,12 @@ defmodule Sequin.Sinks.Meilisearch.ClientTest do assert error.details.task_id == 456 assert error.details.last_status == "processing" - # Verify we made all 6 attempts (1 initial + 5 retries) - for i <- 0..5 do + # Verify we made all 11 attempts (1 initial + 10 retries) + for i <- 0..10 do assert_receive {:task_check, ^i}, 3_000 end - refute_receive {:task_check, 6}, 100 + refute_receive {:task_check, 11}, 100 end test "wait_for_task handles task failure" do