From f35e806e4b92a7f505b95f54eab4d3fe290d74dd Mon Sep 17 00:00:00 2001 From: Chris Boulton Date: Tue, 31 Jan 2023 09:49:48 -0800 Subject: [PATCH] Crash recovery now respects retry_count and retry_delay --- lib/logstash/outputs/s3.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/logstash/outputs/s3.rb b/lib/logstash/outputs/s3.rb index fa3ef9d..86909bf 100644 --- a/lib/logstash/outputs/s3.rb +++ b/lib/logstash/outputs/s3.rb @@ -395,7 +395,7 @@ def clean_temporary_file(file) # The upload process will use a separate uploader/threadpool with less resource allocated to it. # but it will use an unbounded queue for the work, it may take some time before all the older files get processed. def restore_from_crash - @crash_uploader = Uploader.new(bucket_resource, @logger, CRASH_RECOVERY_THREADPOOL) + @crash_uploader = Uploader.new(bucket_resource, @logger, CRASH_RECOVERY_THREADPOOL, retry_count: @retry_count, retry_delay: @retry_delay) temp_folder_path = Pathname.new(@temporary_directory) files = Dir.glob(::File.join(@temporary_directory, "**/*"))