collect_failed_records

in lib/fluent/plugin/kinesis_helper/api.rb [98:110]

• 12 lines of code
• 2 McCabe index (conditional complexity)

      def collect_failed_records(records, res)
        failed_records = []
        results(res).each_with_index do |record, index|
          next unless record[:error_code]
          failed_records.push(
            original:      records[index],
            error_code:    record[:error_code],
            error_message: record[:error_message]
          )
        end
        failed_records
      end