lib/realogy/tasks/realogy.rake in realogy-0.6.6 vs lib/realogy/tasks/realogy.rake in realogy-0.6.7
- old
+ new
@@ -93,10 +93,10 @@
end
def perform_delta_update_for klass, since
return unless %w(agents companies listings offices teams).include?(plural = klass.to_s.tableize.split("/").last)
call = "get_#{plural}_delta".to_sym
- Realogy::DataSync.client.send(call, {since: since.to_i.minutes.ago}).each do |hash|
+ Realogy::DataSync.client.send(call, {since: since.to_i.minutes.ago, followNext: true}).each do |hash|
case hash["action"]
when "Delete"
klass.find_by(entity_id: hash["id"]).try(:destroy)
when "Upsert"
hash["class"] = klass.to_s