实时打印状态
()
| 316 | start_time = time.time() |
| 317 | |
| 318 | def print_status(): |
| 319 | """实时打印状态""" |
| 320 | queue_size = benchmark.get_queue_size() if benchmark else 0 |
| 321 | print(f"\r🔄 Inferred: {stats['inference_done']}/{total_tasks} | " |
| 322 | f"Queue: {queue_size}/{BATCH_SIZE} | " |
| 323 | f"Batches: {stats['batches_evaluated']} | " |
| 324 | f"Errors: {stats['direct_saved']}", end="", flush=True) |
| 325 | |
| 326 | async def inference_and_queue_worker(task: Task): |
| 327 | """ |
no test coverage detected