(tasks: set[asyncio.Task])
| 171 | |
| 172 | |
| 173 | async def cancel_tasks(tasks: set[asyncio.Task]) -> None: |
| 174 | # Cancel any pending, and wait for the cancellation to |
| 175 | # complete i.e. finish any remaining work. |
| 176 | for task in tasks: |
| 177 | task.cancel() |
| 178 | await asyncio.gather(*tasks, return_exceptions=True) |
| 179 | raise_task_exceptions(tasks) |
| 180 | |
| 181 | |
| 182 | def raise_task_exceptions(tasks: set[asyncio.Task]) -> None: |
no test coverage detected
searching dependent graphs…