diff --git a/lib/fluent/plugin/in_opensearch.rb b/lib/fluent/plugin/in_opensearch.rb
index 692c8fd..3b98712 100644
--- 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