skillfed

distributed

Distributed scheduler for Dask

distributed v2026.7.1 8.4M downloads/30d#1,625 on PyPI1,676
Permissive license BSD-3-Clause Active released

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 distributed

uv

uv add distributed

poetry

poetry add distributed

Installing 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

Development Status :: 5 - Production/StableIntended Audience :: DevelopersIntended Audience :: Science/ResearchOperating System :: OS IndependentProgramming Language :: PythonProgramming Language :: Python :: 3Programming Language :: Python :: 3 :: OnlyProgramming Language :: Python :: 3.10Programming Language :: Python :: 3.11Programming Language :: Python :: 3.12Programming Language :: Python :: 3.13Programming Language :: Python :: 3.14Topic :: Scientific/EngineeringTopic :: System :: Distributed Computing

Tags

distributed task schedulerparallel computation frameworkdask distributed computingmulti-machine workload scalingcluster job scheduler python
parallel-computingcluster-schedulingdask-ecosystem

More Scientific/Engineering packages