distributed
Distributed scheduler for Dask
What it is and what it does
Distributed is a scheduler and runtime that coordinates parallel and distributed computation for Dask. It manages task scheduling, data movement, and fault tolerance across a cluster of workers, allowing you to run computations on multiple machines or cores as if they were a single pool. The package handles the low-level coordination—worker lifecycle, task graph execution, communication—so you focus on expressing your computation in Dask.
You typically use it by creating a Client that connects to a cluster (local or remote), then submitting Dask graphs or collections through that client. It depends on Tornado for async networking, Cloudpickle for serialization, and several utility libraries (toolz, sortedcontainers, locket, msgpack) to manage scheduling state and inter-process communication. The package is production-stable and actively maintained.
Use it for:
- Scale data processing pipelines across a cluster without rewriting code for distributed execution.
- Run machine learning training or inference jobs in parallel across multiple GPUs or nodes.
- Execute long-running batch computations that would timeout or exhaust memory on a single machine.
- Coordinate complex workflows with dependencies between tasks across a heterogeneous cluster.
- Monitor and debug distributed workloads through the scheduler's built-in diagnostics and web dashboard.
Worth the install?
AI-flagged interpretation of the facts on this page — verify before relying
Distributed provides a scheduler and runtime for parallel and distributed computation using Dask, enabling you to scale Python workloads across multiple machines or cores.
Yes. Distributed is production-stable, actively maintained, and widely used for scaling Dask workloads. Install friction is low, dependencies are well-established, and there are no known vulnerabilities. Choose it if you need to parallelize or distribute computation beyond a single machine; if you only need local parallelism, Dask alone may suffice.
Install
distributed on PyPI
pip
pip install distributeduv
uv add distributedpoetry
poetry add distributedInstalling distributed
Before you install
Low install friction with a pure-Python wheel. Active maintenance with a recent release (31 days ago) and ongoing commits. Supports current Python versions (3.10–3.14).
License in practice
BSD-3-Clause is permissive; you may use, modify, and distribute this package freely in commercial and private projects with minimal restrictions.
Quickstart
pip install distributed
from distributed import Client
client = Client()
result = client.submit(lambda x: x + 1, 1).result()
Requires Python 3.10 or later. Typically used with Dask; standalone use is possible but limited.
Verify before relying
- Whether the package works reliably on all supported Python versions (3.10–3.14) in production environments.
- Performance characteristics and scalability limits for different cluster sizes and workload types.
Package facts
| License | BSD-3-Clause (permissive) |
| Python support | supports the current Python release (>=3.10) |
| Install friction | low — pure-Python wheel |
| Runtime dependencies | 14 — click, cloudpickle, dask, jinja2, locket, msgpack, packaging, psutil, pyyaml, sortedcontainers, tblib, toolz, tornado, zict |
| Maintenance | actively maintained — 31 days since the last release |
| Last repo commit | |
| First released | |
| Downloads | 8,413,098/month — #1,625 on PyPI (30-day window, as of 2026-08-14) |
| Known vulnerabilities | none known (OSV.dev, checked 2026-08-14) |
Evidence: distributed-2026.7.1-py3-none-any.whl
Tags
More Scientific/Engineering packages
NumPy provides an N-dimensional array object…
permissive · top 100 on PyPI
pandaspandas provides fast, flexible data structures…
permissive · top 100 on PyPI
scipyscipy provides numerical algorithms for…
permissive · top 100 on PyPI
scikit-learnscikit-learn provides a comprehensive Python…
permissive · top 1,000 on PyPI
dilldill extends Python's pickle module to…
permissive · top 1,000 on PyPI
multiprocessMultiprocess is an enhanced fork of Python's…
permissive · top 1,000 on PyPI
coiledCoiled is a Python client library that…
unclear · top 5,000 on PyPI
daskDask is a parallel computing library that…
permissive · top 1,000 on PyPI
dask-jobqueueDeploys Dask distributed computing clusters on…
permissive · top 15,000 on PyPI
mitogenMitogen is a library for writing distributed…
permissive · top 15,000 on PyPI
anyscaleAnyscale provides a command-line interface and…
unclear · top 5,000 on PyPI
prefect-daskIntegrates Prefect workflow orchestration with…
permissive · top 15,000 on PyPI
dask-imageDistributed image processing using Dask,…
permissive · top 15,000 on PyPI
lithopsLithops is a Python framework for running…
permissive · top 15,000 on PyPI
ipyparallelManages clusters of IPython processes for…
permissive · top 15,000 on PyPI
dask-geopandasDask-GeoPandas parallelizes geospatial…
permissive · top 15,000 on PyPI