class ResetDataOutputAgents < ActiveRecord::Migration
  def up
    Agents::DataOutputAgent.find_each do |agent|
      agent.memory = {}
      agent.save(validate: false)
      agent.latest_events(true)
    end
  end
end

Reset memory of all DataOutputAgents for the last fix to take effect
Reset memory of all DataOutputAgents for the last fix to take effect
