def METHOD_NAME(self, data):
    bucket = div_clip(time.time(), self.batch_window_s)
    if self.do_print:
        logger.debug(repr(data))
    with self.mutex:
        self.records_queue[bucket].append(data)