dask/distributed

View on GitHub

A distributed task scheduler for Dask

Stars: 1.7k
Forks: 778
Open beginner issues: 0
Indexed issues: 1.2k
Avg merge: 2h 50m
Merged PRs (30d): 3

Dominant language: Python
License: BSD-3-Clause
Last GitHub push: Aug 26, 2026
Latest indexed: Sep 15, 2026
Contributing guide: Contributing guide
Code of conduct: No code of conduct
Beginner labels: help wanted good first issue

Open All

1248 open issues indexed

enable `xfail_strict=True` - and stop using `@pytest.mark.xfail` for flaky tests Open

tests

dask/distributed#6071 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Disable profiler in tests? Open

diagnostics feature tests

dask/distributed#6075 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
`test_stress_scatter_death` fails with state machine AssertionError Open

dask/distributed#6076 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Refactor report generation logic into a separate repository Open

dask/distributed#6079 · 4 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Possible lead for `WARNING - full garbage collections took XY% CPU time recently` on CI Open

dask/distributed#6080 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Scheduler-side task prioritization is partially untested Open

tests

dask/distributed#6084 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
How should our test matrix look like? Open

discussion

dask/distributed#6085 · 15 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Missing test: duplicates in Worker.ready Open

tests

dask/distributed#6096 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Better description and warnings for using `n_workers=auto` Open

dask/distributed#6097 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Dashboard memory/CPU increases when dashboard is used, making scheduler unresponsive Open

bug diagnostics good second issue p2 performance regression

dask/distributed#6103 · 11 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[Retrospective] Use of ContextVars for passing stimulus_id's within the Scheduler Open

dask/distributed#6107 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
dask serialization for cuda pytorch tensors Open

dask/distributed#6111 · 3 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Include `BatchedSend` state in cluster dumps Open

diagnostics

dask/distributed#6114 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Workers with multiple resources may be underutilized Open

dask/distributed#6136 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Missing input data for a task should fail worker, not the task Open

stability

dask/distributed#6142 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
iPython throws segfault when calling distributed.Client() Open

dask/distributed#6151 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
pytest-instafail ? Open

tests

dask/distributed#6157 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
No longer start stopped loops in LoopRunner to allow the use of asyncio.run Open

dask/distributed#6163 · 12 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Dask security support for specifying a more specific protocol version. Open

dask/distributed#6168 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Set worker memory limits at OS level? Open

memory stability

dask/distributed#6177 · 16 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
AssertionError: Status.created Open

dask/distributed#6183 · 14 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[Discussion] Structured concurrency Open

discussion

dask/distributed#6201 · 6 comments · 10 reactions · 0 assignees · Indexed Sep 15, 2026
Support for wheels when installing dependencies with PipInstall plugin Open

dask/distributed#6202 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
serialize and deserialize do not maintain numpy matrix type Open

dask/distributed#6203 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
[Tasks from tasks] Create collections with number of chunks not known at graph definition time Open

discussion feature

dask/distributed#6204 · 1 comment · 3 reactions · 0 assignees · Indexed Sep 15, 2026
Find the future/partition/file that caused error in Pandas operations Open

dask/distributed#6209 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Investigate asyncio.wait_for for possible bug Open

asyncio

dask/distributed#6211 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Reserve memory capacity in worker operations? Open

discussion memory

dask/distributed#6212 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
flaky test_last_in_first_out[queue on worker] Open

flaky test

dask/distributed#6216 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Monitor spilled data that is still referenced Open

memory

dask/distributed#6220 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
replace gen.coroutine usage with `async def` Open

asyncio hygiene

dask/distributed#6221 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
test_ucx::test_transpose randomly hangs on gpuCI Open

flaky test

dask/distributed#6222 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
`retire_workers(remove=False)` has no effect? Open

bug

dask/distributed#6227 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Unmanaged (Old) memory hanging Open

dask/distributed#6232 · 17 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Include `Worker._missing_dep_flight` in cluster dumps Open

diagnostics enhancement good first issue stability

dask/distributed#6243 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Feature Request: More fully supported actors Open

feature

dask/distributed#6249 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
PyNVML import slowdown? Open

dask/distributed#6247 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Ensure TaskState instances are released on Scheduler and Worker Open

dask/distributed#6250 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Introduce timeout in retire_workers Open

memory

dask/distributed#6252 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
[test coverage] decide_workers never returns None in the unit tests Open

tests

dask/distributed#6254 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
dask in pyscript Open

dask/distributed#6257 · 5 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Allow client.get() without key to return results of all sinks Open

dask/distributed#6258 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
asyncio.exceptions.TimeoutError: Nanny failed to start in 60 seconds Open

dask/distributed#6261 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Enable scheduler to output worker logs to stdout Open

dask/distributed#6264 · 3 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Use compressors collection library Open

dask/distributed#6265 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
if `await worker.close()` fails - subsequent `await close()` calls hang forever Open

bug core

dask/distributed#6279 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
`serialize`'s `on_error` missing cases Open

dask/distributed#6284 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Compress larger buffers Open

dask/distributed#6286 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
CI failure from `test_flight_to_executing_via_cancelled_resumed` Open

flaky test

dask/distributed#6287 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
On CI `test_cluster_info` failed with `LEAKED` status Open

flaky test

dask/distributed#6288 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026

dask/distributed

Get new issues in your inbox