retrying_submit

in lib/logstash/plugin_mixins/opensearch/common.rb [95:122]

• 17 lines of code
• 9 McCabe index (conditional complexity)

    def retrying_submit(actions)
      
      submit_actions = actions

      sleep_interval = @retry_initial_interval

      while submit_actions && submit_actions.length > 0

        
        begin
          submit_actions = submit(submit_actions)
          if submit_actions && submit_actions.size > 0
            @logger.info("Retrying individual bulk actions that failed or were rejected by the previous bulk request", count: submit_actions.size)
          end
        rescue => e
          @logger.error("Encountered an unexpected error submitting a bulk request, will retry",
                        message: e.message, exception: e.class, backtrace: e.backtrace)
        end

        
        break if !submit_actions || submit_actions.empty?

        
        
        sleep_interval = sleep_for_interval(sleep_interval)
      end
    end