Get all tasks from benchmark manager.
(benchmark_name: str)
| 249 | |
| 250 | |
| 251 | async def get_all_tasks(benchmark_name: str) -> List[Dict]: |
| 252 | """Get all tasks from benchmark manager.""" |
| 253 | tasks = [] |
| 254 | logger.info(f"| 🔄 Resetting progress for {benchmark_name}...") |
| 255 | task_data = await benchmark_manager.reset(benchmark_name) |
| 256 | |
| 257 | while task_data is not None: |
| 258 | tasks.append(task_data) |
| 259 | task_data = await benchmark_manager.step(benchmark_name) |
| 260 | |
| 261 | return tasks |
| 262 | |
| 263 | async def get_all_incorrect_tasks(experiment_file: str, benchmark_name: str) -> List[Any]: |
| 264 | """ |
no test coverage detected