File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
tensorrt_llm/bench/benchmark/utils Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change 6
6
from itertools import chain
7
7
from typing import List , Optional , Set , Tuple
8
8
9
+ import tqdm
9
10
from zmq import PUSH
10
11
from zmq .asyncio import Context
11
12
@@ -238,12 +239,14 @@ async def async_benchmark(
238
239
post_proc_params , submit_finished ))
239
240
240
241
logger .info ("Starting benchmark..." )
242
+ pbar = tqdm .tqdm (total = len (requests ), desc = "Benchmarking" )
241
243
while not submit_finished .is_set () or backend .busy or not outbox .empty (
242
244
):
243
245
try :
244
246
item : PerfItemTuple = await asyncio .wait_for (outbox .get (),
245
247
timeout = 1.0 )
246
248
statistics .register_request_perf_item (item )
249
+ pbar .update (1 )
247
250
except asyncio .TimeoutError :
248
251
logger .debug ("No items in queue. Continuing." )
249
252
You can’t perform that action at this time.
0 commit comments