(group: list[tuple[int, dict[str, Any]]])
| 966 | results: list[dict[str, Any] | None] = [None] * len(calls) |
| 967 | |
| 968 | async def run_group(group: list[tuple[int, dict[str, Any]]]) -> None: |
| 969 | for idx, call in group: |
| 970 | try: |
| 971 | out = await self._dispatch_call(call) |
| 972 | results[idx] = {"ok": True, "result": out} |
| 973 | except Exception as exc: |
| 974 | results[idx] = {"ok": False, "error": str(exc)} |
| 975 | |
| 976 | await asyncio.gather(*(run_group(g) for g in groups.values())) |
| 977 | return [r if r is not None else {"ok": False, "error": "missing"} for r in results] |
nothing calls this directly
no test coverage detected