# File lib/taps/data_stream.rb, line 330 def verify_stream key = primary_key ds = table.order(*order_by) current_filter = ds.max(key.sql_number) # set the current filter to the max of the primary key state[:filter] = current_filter # clear out the last_fetched value so it can restart from scratch state[:last_fetched] = nil log.debug "DataStreamKeyed#verify_stream -> state: #{state.inspect}" end