code: def enable_writes(self):
          
          self.write_buffer = []
          self.flush_lock = threading.RLock()
          self.flush_thread = FlushThread(self.max_batch_time,
                                          self._flush_writes)
docs: Restores the state of the batched queue for writing.