()
| 1263 | return checkpoints[i] |
| 1264 | |
| 1265 | async def _dispatch(): |
| 1266 | tasks = [_ckpt(i) if i in checkpoints |
| 1267 | else _report_one(i, sig, ents, target, args, agent_env, reports_root) |
| 1268 | for i, (sig, ents) in enumerate(items)] |
| 1269 | if args.parallel: |
| 1270 | return await asyncio.gather(*tasks, return_exceptions=True) |
| 1271 | out = [] |
| 1272 | for t in tasks: |
| 1273 | out.append(await t) |
| 1274 | return out |
| 1275 | |
| 1276 | results = asyncio.run(_dispatch()) |
| 1277 |
no test coverage detected