process_records

in spec/kcl_process_spec.rb [16:28]

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

    def process_records(records, checkpointer)
      seq = records[0]['sequenceNumber']
      begin
        checkpointer.checkpoint(seq)
      rescue CheckpointError => cpe
        if cpe.value == 'ThrottlingException'
          checkpointer.checkpoint(seq)
        else
          raise
        end
      end
    end