code: def time_delta_pusher(please_stop, appender, queue, interval):
      
  
      next_run = time() + interval
  
      while not please_stop:
          profiler = Thread.current().cprofiler
          profiler.disable()
          (Till(till=next_run) | please_stop).wait()
          profiler.enable()
  
          next_run = time() + interval
          logs = queue.pop_all()
          if not logs:
              continue
  
          lines = []
          for log in logs:
              try:
                  if log is THREAD_STOP:
                      please_stop.go()
                      next_run = time()
                  else:
                      expanded = expand_template(log.get("template"), log.get("params"))
                      lines.append(expanded)
              except Exception as e:
                  location = log.get('params', {}).get('location', {})
                  Log.warning("Trouble formatting log from {{location}}", location=location, cause=e)
                  # SWALLOW ERROR, GOT TO KEEP RUNNING
          try:
              appender(CR.join(lines) + CR)
          except Exception as e:
  
              sys.stderr.write(str("Trouble with appender: ") + str(e.__class__.__name__) + str(CR))
docs: appender - THE FUNCTION THAT ACCEPTS A STRING
      queue - FILLED WITH LOG ENTRIES {"template":template, "params":params} TO WRITE
      interval - timedelta
      USE IN A THREAD TO BATCH LOGS BY TIME INTERVAL