Description
Describe the issue:
Minimal Complete Verifiable Example:
from dask.distributed import Client, Worker, Scheduler, wait
import pyperf
def inc(x):
return x + 1
async def benchmark():
async with Scheduler() as scheduler:
async with Worker(scheduler.address):
async with Client(scheduler.address, asynchronous=True) as client:
futures = client.map(inc, range(100))
for _ in range(10):
futures = client.map(inc, futures)
await wait(futures)
if __name__ == "__main__":
runner = pyperf.Runner()
runner.metadata['description'] = "Benchmark dask"
runner.bench_async_func('dask', benchmark)Anything else we need to know?:
Environment:
- Dask version: 2024.5.0
- Python version: 3.13 (main branch, future 3.13 beta 1)
- Operating System: Windows 11
- Install method (conda, pip, source): pip