lib/lhm/chunker.rb in lhm-1.1.0 vs lib/lhm/chunker.rb in lhm-1.2.0

- old
+ new

@@ -1,6 +1,6 @@ -# Copyright (c) 2011, SoundCloud Ltd., Rany Keddo, Tobias Bielohlawek, Tobias +# Copyright (c) 2011 - 2013, SoundCloud Ltd., Rany Keddo, Tobias Bielohlawek, Tobias # Schmidt require 'lhm/command' require 'lhm/sql_helper' @@ -81,10 +81,10 @@ end end def execute up_to do |lowest, highest| - affected_rows = update(copy(lowest, highest)) + affected_rows = @connection.update(copy(lowest, highest)) if affected_rows > 0 sleep(throttle_seconds) end