code: def record_occupation_updates(self, updates, source, version):
          
          now = int(time.time())
          # Put it on the recordQueue and notify the worker thread.
          with self.recordCond:
              self.recordQueue.append((now, updates, source))
              self.recordCond.notify()
docs: Records an occupation update