def force_due
      r = self
      r.update_attributes(:started_at=>(Time.now.utc - Jobtracker.runner_read_freq - 1.second))
    end
def force_due
      r = self
      r.update_attributes(:started_at=>(Time.now.utc - Jobtracker.runner_read_freq - 1.second))
    end
update runner started_at
to be whatever the notification is - 1.second
which will force runner to be due