update bench
This commit is contained in:
25
bench.py
25
bench.py
@@ -1,20 +1,27 @@
|
|||||||
import os
|
import os
|
||||||
import time
|
import time
|
||||||
import torch
|
from random import randint, seed
|
||||||
from nanovllm import LLM, SamplingParams
|
from nanovllm import LLM, SamplingParams
|
||||||
|
# from vllm import LLM, SamplingParams
|
||||||
|
|
||||||
|
|
||||||
batch_size = 256
|
seed(0)
|
||||||
seq_len = 1024
|
num_seqs = 256
|
||||||
max_tokens = 512
|
max_input_len = 1024
|
||||||
|
max_ouput_len = 1024
|
||||||
|
|
||||||
path = os.path.expanduser("~/huggingface/Qwen3-0.6B/")
|
path = os.path.expanduser("~/huggingface/Qwen3-0.6B/")
|
||||||
llm = LLM(path, enforce_eager=False)
|
llm = LLM(path, enforce_eager=False, max_model_len=4096)
|
||||||
|
|
||||||
prompt_token_ids = torch.randint(0, 10240, (batch_size, seq_len)).tolist()
|
prompt_token_ids = [[randint(0, 10000) for _ in range(randint(100, max_input_len))] for _ in range(num_seqs)]
|
||||||
sampling_params = SamplingParams(temperature=0.6, ignore_eos=True, max_tokens=max_tokens)
|
sampling_params = [SamplingParams(temperature=0.6, ignore_eos=True, max_tokens=randint(100, max_ouput_len)) for _ in range(num_seqs)]
|
||||||
|
# uncomment the following line for vllm
|
||||||
|
# prompt_token_ids = [dict(prompt_token_ids=p) for p in prompt_token_ids]
|
||||||
|
|
||||||
|
llm.generate(["Benchmark: "], SamplingParams())
|
||||||
t = time.time()
|
t = time.time()
|
||||||
llm.generate(prompt_token_ids, sampling_params)
|
llm.generate(prompt_token_ids, sampling_params)
|
||||||
throughput = batch_size * max_tokens / (time.time() - t)
|
t = (time.time() - t)
|
||||||
print(f"Throughput: {throughput: .2f}")
|
total_tokens = sum(sp.max_tokens for sp in sampling_params)
|
||||||
|
throughput = total_tokens / t
|
||||||
|
print(f"Total: {total_tokens}, Time: {t:.2f}s, Throughput: {throughput: .2f}")
|
||||||
|
|||||||
@@ -25,5 +25,5 @@ outputs = llm.generate(prompts, sampling_params)
|
|||||||
|
|
||||||
for prompt, output in zip(prompts, outputs):
|
for prompt, output in zip(prompts, outputs):
|
||||||
print("\n")
|
print("\n")
|
||||||
print(f"Prompt: {prompt}")
|
print(f"Prompt: {prompt!r}")
|
||||||
print(f"Completion: {output['text']}")
|
print(f"Completion: {output['text']!r}")
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ from nanovllm.engine.sequence import Sequence
|
|||||||
def compute_hash(token_ids: list[int], prefix: int = -1):
|
def compute_hash(token_ids: list[int], prefix: int = -1):
|
||||||
h = xxhash.xxh64()
|
h = xxhash.xxh64()
|
||||||
if prefix != -1:
|
if prefix != -1:
|
||||||
h.update(prefix.to_bytes(8))
|
h.update(prefix.to_bytes(8, "little"))
|
||||||
h.update(np.array(token_ids).tobytes())
|
h.update(np.array(token_ids).tobytes())
|
||||||
return h.intdigest()
|
return h.intdigest()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user