Index

A

abort() (distributed.comm.Comm method) acquire() (distributed.Lock method) adapt() (distributed.SpecCluster 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 property)

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 property) 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 property)

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 property)

Listener (class in distributed.comm.core) local_address() (distributed.comm.Comm property) LocalCluster (class in distributed) 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)

new_worker_spec() (distributed.SpecCluster 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 property) 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 3148

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

scale() (distributed.SpecCluster method) scale_up() (distributed.SpecCluster 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) 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) SpecCluster (class in distributed) 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)