Get Started
Install
Examples
Tutorial
Why Dask?
Use Cases
Talks
Try Online
Algorithms
Arrays
Dataframes
Bags
Delayed (custom)
Futures (real-time)
Machine Learning
XArray
Deploy
Hadoop / Yarn
Helm
HPC
Kubernetes
Local
Community
Ask for Help
Github
Stack Overflow
Twitter
Developer Blog
Dask.distributed
0+unknown
Getting Started
Install Dask.Distributed
Quickstart
Setup
Client
API
Examples
Frequently Asked Questions
Build Understanding
Diagnosing Performance
Efficiency
Limitations
Data Locality
Managing Computation
Managing Memory
Prioritizing Work
Related Work
Resilience
Scheduling Policies
Scheduling State
Worker
Work Stealing
Additional Features
Actors
Adaptive Deployments
Asynchronous Operation
Local Cluster
IPython Integration
Joblib Integration
Prometheus Monitoring
Publish Datasets
Data Streams with Queues
Worker Resources
Launch Tasks from Tasks
TLS/SSL
Web Interface
Developer Documentation
Changelog
Communications
Development Guidelines
Foundations
Journey of a Task
Protocol
Serialization
Scheduler Plugins
Worker Plugins
Dask.distributed
Docs
»
Index
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
A
abort() (distributed.comm.Comm method)
acquire() (distributed.Lock method)
Adaptive (class in distributed.deploy)
adaptive_target() (distributed.scheduler.Scheduler method)
add() (distributed.as_completed method)
add_client() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
add_done_callback() (distributed.Future method)
add_keys() (distributed.scheduler.Scheduler method)
add_plugin() (distributed.scheduler.Scheduler method)
add_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
address (distributed.scheduler.WorkerState attribute)
as_completed (class in distributed)
asynchronous (distributed.Client attribute)
B
Backend (class in distributed.comm.registry)
batches() (distributed.as_completed method)
broadcast() (distributed.scheduler.Scheduler method)
C
call_stack() (distributed.Client method)
cancel() (distributed.Client method)
(distributed.Future method)
cancel_key() (distributed.scheduler.Scheduler method)
cancelled() (distributed.Future method)
check_idle_saturated() (distributed.scheduler.Scheduler method)
Client (class in distributed)
client_heartbeat() (distributed.scheduler.Scheduler method)
client_releases_keys() (distributed.scheduler.Scheduler method)
ClientState (class in distributed.scheduler)
close() (distributed.Client method)
(distributed.comm.Comm method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
close_worker() (distributed.scheduler.Scheduler method)
closed() (distributed.comm.Comm method)
coerce_address() (distributed.scheduler.Scheduler method)
coerce_hostname() (distributed.scheduler.Scheduler method)
Comm (class in distributed.comm)
compute() (distributed.Client method)
connect() (in module distributed.comm)
contact_address (distributed.comm.core.Listener attribute)
count() (distributed.as_completed method)
current() (distributed.Client class method)
D
dask_deserialize() (in module distributed.protocol.serialize)
dask_serialize() (in module distributed.protocol.serialize)
decide_worker() (distributed.scheduler.Scheduler method)
(in module distributed.scheduler)
delete() (distributed.Variable method)
deserialize() (in module distributed.protocol.serialize)
done() (distributed.Future method)
E
exception() (distributed.Future method)
extra_info (distributed.comm.Comm attribute)
F
feed() (distributed.scheduler.Scheduler method)
fire_and_forget() (in module distributed)
Future (class in distributed)
futures_of() (in module distributed)
G
gather() (distributed.Client method)
(distributed.scheduler.Scheduler method)
get() (distributed.Client method)
(distributed.Queue method)
(distributed.Variable method)
get_address_host() (distributed.comm.registry.Backend method)
(in module distributed.comm)
get_address_host_port() (distributed.comm.registry.Backend method)
get_client() (in module distributed)
get_comm_cost() (distributed.scheduler.Scheduler method)
get_connection_args() (distributed.security.Security method)
get_connector() (distributed.comm.registry.Backend method)
get_dataset() (distributed.Client method)
get_executor() (distributed.Client method)
get_futures_error() (distributed.recreate_exceptions.ReplayExceptionClient method)
get_listen_args() (distributed.security.Security method)
get_listener() (distributed.comm.registry.Backend method)
get_local_address_for() (distributed.comm.registry.Backend method)
get_metadata() (distributed.Client method)
get_restrictions() (distributed.Client class method)
get_scheduler_logs() (distributed.Client method)
get_task_duration() (distributed.scheduler.Scheduler method)
get_task_stream (class in distributed)
get_task_stream() (distributed.Client method)
get_tls_config_for_role() (distributed.security.Security method)
get_versions() (distributed.Client method)
get_worker() (in module distributed)
get_worker_logs() (distributed.Client method)
get_worker_service_addr() (distributed.scheduler.Scheduler method)
H
handle_long_running() (distributed.scheduler.Scheduler method)
handle_worker() (distributed.scheduler.Scheduler method)
has_ready() (distributed.as_completed method)
has_what() (distributed.Client method)
I
identity() (distributed.scheduler.Scheduler method)
is_empty() (distributed.as_completed method)
L
list_datasets() (distributed.Client method)
listen() (in module distributed.comm)
listen_address (distributed.comm.core.Listener attribute)
Listener (class in distributed.comm.core)
local_address (distributed.comm.Comm attribute)
LocalCluster (class in distributed.deploy.local)
Lock (class in distributed)
M
map() (distributed.Client method)
N
Nanny (class in distributed.nanny)
nbytes() (distributed.Client method)
ncores() (distributed.Client method)
new_task() (distributed.scheduler.Scheduler method)
next_batch() (distributed.as_completed method)
normalize_address() (in module distributed.comm)
normalize_collection() (distributed.Client method)
nthreads() (distributed.Client method)
P
parse_address() (in module distributed.comm)
peer_address (distributed.comm.Comm attribute)
persist() (distributed.Client method)
processing() (distributed.Client method)
profile() (distributed.Client method)
progress() (in module distributed.diagnostics)
proxy() (distributed.scheduler.Scheduler method)
publish_dataset() (distributed.Client method)
put() (distributed.Queue method)
Python Enhancement Proposals
PEP 3184
Q
qsize() (distributed.Queue method)
Queue (class in distributed)
R
read() (distributed.comm.Comm method)
rebalance() (distributed.Client method)
(distributed.scheduler.Scheduler method)
recommendations() (distributed.deploy.Adaptive method)
recreate_error_locally() (distributed.recreate_exceptions.ReplayExceptionClient method)
reevaluate_occupancy() (distributed.scheduler.Scheduler method)
register_generic() (in module distributed.protocol.serialize)
register_worker_callbacks() (distributed.Client method)
register_worker_plugin() (distributed.Client method)
(distributed.scheduler.Scheduler method)
rejoin() (in module distributed)
release() (distributed.Lock method)
remove_client() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
remove_plugin() (distributed.scheduler.Scheduler method)
remove_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
ReplayExceptionClient (class in distributed.recreate_exceptions)
replicate() (distributed.Client method)
(distributed.scheduler.Scheduler method)
report() (distributed.scheduler.Scheduler method)
Reschedule (class in distributed)
reschedule() (distributed.scheduler.Scheduler method)
resolve_address() (distributed.comm.registry.Backend method)
(in module distributed.comm)
restart() (distributed.Client method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
result() (distributed.Future method)
retire_workers() (distributed.Client method)
(distributed.scheduler.Scheduler method)
retry() (distributed.Client method)
(distributed.Future method)
rpc (class in distributed.core)
run() (distributed.Client method)
run_coroutine() (distributed.Client method)
run_function() (distributed.scheduler.Scheduler method)
run_on_scheduler() (distributed.Client method)
S
scatter() (distributed.Client method)
(distributed.scheduler.Scheduler method)
Scheduler (class in distributed.scheduler)
scheduler_info() (distributed.Client method)
SchedulerPlugin (class in distributed.diagnostics.plugin)
secede() (in module distributed)
Security (class in distributed.security)
send_task_to_worker() (distributed.scheduler.Scheduler method)
serialize() (in module distributed.protocol.serialize)
Server (class in distributed.core)
set() (distributed.Variable method)
set_metadata() (distributed.Client method)
setup() (distributed.diagnostics.plugin.WorkerPlugin method)
shutdown() (distributed.Client method)
start() (distributed.Client method)
(distributed.comm.core.Listener method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
start_ipython() (distributed.scheduler.Scheduler method)
start_ipython_scheduler() (distributed.Client method)
start_ipython_workers() (distributed.Client method)
stimulus_cancel() (distributed.scheduler.Scheduler method)
stimulus_missing_data() (distributed.scheduler.Scheduler method)
stimulus_task_erred() (distributed.scheduler.Scheduler method)
stimulus_task_finished() (distributed.scheduler.Scheduler method)
stop() (distributed.comm.core.Listener method)
story() (distributed.scheduler.Scheduler method)
submit() (distributed.Client method)
T
target() (distributed.deploy.Adaptive method)
TaskState (class in distributed.scheduler)
teardown() (distributed.diagnostics.plugin.WorkerPlugin method)
temporary() (distributed.security.Security class method)
traceback() (distributed.Future method)
transition() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.diagnostics.plugin.WorkerPlugin method)
(distributed.scheduler.Scheduler method)
transition_story() (distributed.scheduler.Scheduler method)
transitions() (distributed.scheduler.Scheduler method)
U
unparse_address() (in module distributed.comm)
unpublish_dataset() (distributed.Client method)
update() (distributed.as_completed method)
update_data() (distributed.scheduler.Scheduler method)
update_graph() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
upload_file() (distributed.Client method)
V
valid_workers() (distributed.scheduler.Scheduler method)
Variable (class in distributed)
W
wait() (in module distributed)
wait_for_workers() (distributed.Client method)
who_has() (distributed.Client method)
Worker (class in distributed.worker)
worker_client() (in module distributed)
worker_objective() (distributed.scheduler.Scheduler method)
worker_send() (distributed.scheduler.Scheduler method)
WorkerPlugin (class in distributed.diagnostics.plugin)
workers_list() (distributed.scheduler.Scheduler method)
workers_to_close() (distributed.deploy.Adaptive method)
(distributed.scheduler.Scheduler method)
WorkerState (class in distributed.scheduler)
write() (distributed.comm.Comm method)
write_scheduler_file() (distributed.Client method)