Function flush_buffer

eval/src/vllm_request.py:204–210

(buffer, path)

        log_stats = os.getenv("VLLM_LOG_STATS", "0") == "1"

    def flush_buffer(buffer, path):
        if not buffer or not path:
            return
        with open(path, "a", encoding="utf-8") as f:
            for row in buffer:
                f.write(json.dumps(row, ensure_ascii=False) + "\n")
        buffer.clear()

    with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:
        futures = []