()
| 12 | all_args = list(all_args) |
| 13 | |
| 14 | def new_task(): |
| 15 | with suppress(IndexError): |
| 16 | arg = all_args.pop(0) |
| 17 | task = asyncio.create_task(fn(arg, **global_kwargs)) |
| 18 | tasks[task] = arg |
| 19 | |
| 20 | for _ in range(threads): # Start initial batch of tasks |
| 21 | new_task() |