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 Network
Client
API
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
Configuration
Local Cluster
IPython Integration
Joblib Integration
Publish Datasets
Data Streams with Queues
Worker Resources
Submitting Applications
Launch Tasks from Tasks
TLS/SSL
Web Interface
Developer Documentation
Changelog
Communications
Development Guidelines
Foundations
Journey of a Task
Protocol
Serialization
Scheduler 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)
add_client() (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)
AioClient (class in distributed.asyncio)
as_completed() (in module distributed)
asynchronous (distributed.Client attribute)
B
Backend (class in distributed.comm.registry)
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)
Client (class in distributed)
client_heartbeat() (distributed.scheduler.Scheduler method)
client_releases_keys() (distributed.scheduler.Scheduler method)
ClientState (class in distributed.scheduler)
close() (distributed.asyncio.AioClient method)
(distributed.Client method)
(distributed.comm.Comm method)
(distributed.deploy.local.LocalCluster 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)
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)
finished() (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.asyncio.AioClient method)
(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_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_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_scale_up_kwargs() (distributed.deploy.Adaptive 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_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_what() (distributed.Client method)
I
identity() (distributed.scheduler.Scheduler 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
nbytes() (distributed.Client method)
ncores() (distributed.Client method)
needs_cpu() (distributed.deploy.Adaptive method)
needs_memory() (distributed.deploy.Adaptive method)
normalize_address() (in module distributed.comm)
normalize_collection() (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)
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)
(distributed.scheduler.Scheduler method)
rejoin() (in module distributed)
release() (distributed.Lock method)
remove_client() (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() (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
scale_down() (distributed.deploy.local.LocalCluster method)
scale_up() (distributed.deploy.local.LocalCluster method)
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)
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)
should_scale_up() (distributed.deploy.Adaptive method)
shutdown() (distributed.asyncio.AioClient method)
(distributed.Client method)
start() (distributed.Client method)
(distributed.comm.core.Listener method)
(distributed.scheduler.Scheduler method)
start_ipython() (distributed.scheduler.Scheduler method)
start_ipython_scheduler() (distributed.Client method)
start_ipython_workers() (distributed.Client method)
start_worker() (distributed.deploy.local.LocalCluster 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)
stop_worker() (distributed.deploy.local.LocalCluster method)
story() (distributed.scheduler.Scheduler method)
submit() (distributed.Client method)
T
TaskState (class in distributed.scheduler)
traceback() (distributed.Future method)
transition() (distributed.diagnostics.plugin.SchedulerPlugin 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_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)
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)
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)