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

cancel() (distributed.Client method)
(distributed.Future method)
cancel_key() (distributed.scheduler.Scheduler method)
cancelled() (distributed.Future method)
channel() (distributed.Client method)
cleanup() (distributed.scheduler.Scheduler method)
Client (class in distributed)
client_releases_keys() (distributed.scheduler.Scheduler method)
close() (distributed.Client method)
(distributed.comm.Comm method)
(distributed.deploy.local.LocalCluster method)
(distributed.scheduler.Scheduler method)
close_comms() (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)
correct_time_delay() (distributed.scheduler.Scheduler method)

D

decide_worker() (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)
Future (class in 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_restrictions() (distributed.Client static method)
get_task_duration() (distributed.scheduler.Scheduler method)
get_versions() (distributed.Client method)
(distributed.scheduler.Scheduler method)
get_worker() (in module distributed)
get_worker_service_addr() (distributed.scheduler.Scheduler method)

H

handle_client() (distributed.scheduler.Scheduler method)
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)

M

map() (distributed.Client method)

N

nbytes() (distributed.Client method)
ncores() (distributed.Client 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)
progress() (in module distributed.diagnostics)
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_serialization() (in module distributed.protocol.serialize)
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)
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)
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)
shutdown() (distributed.Client method)
stacks() (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)
submit() (distributed.Client method)

T

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)
workers_list() (distributed.scheduler.Scheduler method)
workers_to_close() (distributed.scheduler.Scheduler method)
write() (distributed.comm.Comm method)