rewritten retry state with the above recommendations in mind.

Signed-off-by: Oleh <trahterber@gmail.com>
fluent · Apr 25, 2024 · 52fd079 · 52fd079
1 parent 6529888
commit 52fd079
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/fluent/plugin/in_opensearch.rb b/lib/fluent/plugin/in_opensearch.rb
@@ -349,8 +349,10 @@ def update_retry_state(error=nil)
         log.warn("failed to connect or search.", retry_times: @retry.steps, next_retry_time: @retry.next_time.round, error: error.message)
         sleep(@retry.next_time - Time.now)
       else
-        log.debug("retry succeeded.") unless @retry.nil?
-        @retry = nil unless @retry.nil?
+        unless @retry.nil?
+          log.debug("retry succeeded.")
+          @retry = nil
+        end
       end
     end