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

Timed out trying to connect ... : connect() didn't finish in time Open

dask/distributed#4080 · 36 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
`test_tls_reject_certificate` regression Open

dask/distributed#4084 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Creating a Client with set_as_default=False sets client as default Open

dask/distributed#5425 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Investigate performance issues in profiler Open

performance

dask/distributed#4091 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Unable to serialize function with closure including object with custom metadata Open

dask/distributed#4092 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Cluster dies with "failed to deserialize" and "IndexError: pop from empty list" Open

dask/distributed#4099 · 14 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
raise CommClosedError() distributed.comm.core.CommClosedError with tornado.iostream.StreamClosedError: Stream is closedz Open

dask/distributed#4103 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Semaphore and other objects as task condition Open

dask/distributed#4104 · 25 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Adaptive scaling went above the number of available tasks Open

adaptive good second issue

dask/distributed#4108 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Default use jupyter-server-proxy with dask-labextension Open

dask/distributed#4109 · 3 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Hardcoded time outs lead to complete teardown of communication layer Open

dask/distributed#4118 · 5 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
pubsub: not all put() operations are completed Open

dask/distributed#4120 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Exception in thread and deadlock after creating Client Open

dask/distributed#4124 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add helpers to make scheduler state JSON serializable Open

dask/distributed#4126 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add classic line charts Open

dask/distributed#4132 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
KeyError: pickle-protocol when running df.npartitions Open

dask/distributed#4134 · 14 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Dask requires consistent Python hashing Open

dask/distributed#4141 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Constantly having MemoryError exceptions when processing dataframe Open

dask/distributed#4144 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Semaphore gets released too often Open

dask/distributed#4147 · 10 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Persistent client connection Open

dask/distributed#4149 · 9 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add ability to reset stateful dashboards Open

diagnostics

dask/distributed#4159 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Expose or proxy internal IPs of workers for Prometheus monitoring Open

dask/distributed#4160 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Flaky test_broken_worker_during_computation Open

flaky test

dask/distributed#4173 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Request for documentation on tuning for scaling to thousand-node cluster Open

dask/distributed#4180 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Clarification of the task graph: are futures allowed in tuples that aren't tasks? Open

dask/distributed#4183 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
WARNING - Memory use is high but worker has no data to store to disk Open

dask/distributed#4193 · 17 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Prioritize the migration of recent expensive to compute data during RM scale down Open

dask/distributed#4202 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Flaky test_tls_specific Open

flaky test

dask/distributed#4215 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
losing GPUs as workers after a while running Open

dask/distributed#4220 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Pub/Sub appears to duplicate messages Open

dask/distributed#4242 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Massive memory (100GB) used by dask-scheduler Open

dask/distributed#4243 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Flaky test_profile_server Open

flaky test

dask/distributed#4251 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Cluster lifecycle management Open

dask/distributed#4263 · 7 comments · 5 reactions · 0 assignees · Indexed Sep 15, 2026
Use HighLevelGraph with Client.map Open

dask/distributed#4282 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Use RSS - SHARED to track memory? Open

dask/distributed#4304 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
"Event loop is closed" in multithreaded environment Open

dask/distributed#4317 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Get actor from other client having it's id Open

dask/distributed#4333 · 0 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Huge memory leak and processes do not restart automatically Open

dask/distributed#4345 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Improve dask dashboard displaying of nested tasks execution Open

dask/distributed#4346 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Track retry counts Open

dask/distributed#4353 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Race condition in distributed.utils.All Open

dask/distributed#4356 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
as_completed with multiple clients can be error-prone Open

dask/distributed#4357 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Memory leaks with sleep despite no data exchange or use of Pandas Open

dask/distributed#4366 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Import errors on workers should be visible in output Open

dask/distributed#4368 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Simplifying serialization of status messages Open

dask/distributed#4376 · 10 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
scheduler_options/scheduler_kwargs inconsistency Open

dask/distributed#4383 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Data loss with `DataFrame.set_index(.., shuffle="disk")` Open

dask/distributed#4386 · 14 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
AttributeError: 'Semaphore' object has no attribute '_periodic_callback_name' Open

dask/distributed#4389 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Sometimes, adaptive and lifetime flags don't play nicely together Open

adaptive

dask/distributed#4394 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Lost progress due to worker-client restart Open

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

dask/distributed

Get new issues in your inbox