From 0344bd178dcb5b32698c50c2bf161127d224ed94 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Fran=C3=A7ois=20Massot?= <francois.massot@gmail.com>
Date: Fri, 14 Jul 2023 12:05:45 +0900
Subject: [PATCH] Avoid exiting http source.

---
 quickwit/quickwit-indexing/src/source/http_source.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/quickwit/quickwit-indexing/src/source/http_source.rs b/quickwit/quickwit-indexing/src/source/http_source.rs
index 78bd9faedb6..4e8d0540495 100644
--- a/quickwit/quickwit-indexing/src/source/http_source.rs
+++ b/quickwit/quickwit-indexing/src/source/http_source.rs
@@ -187,8 +187,9 @@ impl Source for HttpSource {
             .find(|(_, partition_counters)| partition_counters.current_offset < u64::MAX)
         else {
             info!("No more partitions to read from, stopping source.");
-            ctx.send_exit_with_success(doc_processor_mailbox).await?;
-            return Err(ActorExitStatus::Success);
+            info!("Resetting failing URIs and retrying in 1h");
+            self.uri_with_errors.clear();
+            return Ok(Duration::from_secs(3600));
         };
         let uri = partition.0.as_str();
         let lines_result: anyhow::Result<Lines<BufReader<Box<dyn AsyncRead + Send + Unpin>>>> =