collect_failed_records

in lib/fluent/plugin/kinesis_helper/api.rb [127:143]

• 16 lines of code
• 4 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]
              original = case request_type
                         when :streams, :firehose; records[index]
                         when :streams_aggregated; records
                         end
              failed_records.push(
                original:      original,
                error_code:    record[:error_code],
                error_message: record[:error_message]
              )
            end
            failed_records
          end