Dask
Distributed
Dask ML
Examples
Ecosystem
Community
Toggle navigation sidebar
Dask.distributed 2024.4.1 documentation
Getting Started
Install Dask.Distributed
Quickstart
Setup
Client
API
Examples
Word count in HDFS
Frequently Asked Questions
Build Understanding
Diagnosing Performance
Efficiency
Limitations
Data Locality
Logging
Managing Computation
Managing Memory
Prioritizing Work
Related Work
Resilience
Scheduling Policies
Scheduler State Machine
Worker
Worker State Machine
Worker Memory Management
Work Stealing
Why did my worker die?
Additional Features
Actors
Asynchronous Operation
HTTP endpoints
Publish Datasets
Worker Resources
Launch Tasks from Tasks
TLS/SSL
Active Memory Manager
Prometheus monitoring
Fine Performance Metrics
Spans
Developer Documentation
Changelog
Communications
Development Guidelines
Foundations
Journey of a Task
Protocol
Serialization
Plugins
Toggle navigation
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
A
abort() (distributed.comm.Comm method)
acquire() (distributed.Lock method)
(distributed.MultiLock method)
(distributed.Semaphore method)
active_cpu_seconds (distributed.spans.Span property)
ActiveMemoryManagerExtension (class in distributed.active_memory_manager)
ActiveMemoryManagerPolicy (class in distributed.active_memory_manager)
actor (distributed.scheduler.TaskState attribute)
actors (distributed.scheduler.WorkerState attribute)
(distributed.worker_state_machine.WorkerState attribute)
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_dependency() (distributed.scheduler.TaskState method)
add_done_callback() (distributed.Future method)
add_keys() (distributed.scheduler.Scheduler method)
add_plugin() (distributed.scheduler.Scheduler method)
add_replica() (distributed.scheduler.Scheduler method)
(distributed.scheduler.WorkerState method)
add_to_processing() (distributed.scheduler.WorkerState method)
add_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
address (distributed.scheduler.Scheduler property)
(distributed.scheduler.WorkerState attribute)
(distributed.worker_state_machine.WorkerState attribute)
address_safe (distributed.scheduler.Scheduler property)
all_durations (distributed.spans.Span property)
all_running_tasks (distributed.worker_state_machine.WorkerState property)
amm (distributed.Client property)
amm_handler() (distributed.active_memory_manager.ActiveMemoryManagerExtension method)
AMMClientProxy (class in distributed.active_memory_manager)
annotation (distributed.spans.Span property)
annotations (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
as_completed (class in distributed)
as_current() (distributed.Client method)
available_resources (distributed.worker_state_machine.WorkerState attribute)
B
Backend (class in distributed.comm.registry)
BaseWorker (class in distributed.worker_state_machine)
batched_send() (distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
batches() (distributed.as_completed method)
before_close() (distributed.diagnostics.plugin.SchedulerPlugin method)
benchmark_hardware() (distributed.Client method)
(distributed.scheduler.Scheduler method)
broadcast() (distributed.scheduler.Scheduler method)
bulk_schedule_unrunnable_after_adding_worker() (distributed.scheduler.Scheduler method)
busy_workers (distributed.worker_state_machine.WorkerState attribute)
C
call_stack() (distributed.Client method)
cancel() (distributed.Client method)
(distributed.Future method)
cancelled() (distributed.Future method)
candidates (distributed.active_memory_manager.Suggestion attribute)
check_idle_saturated() (distributed.scheduler.Scheduler method)
children (distributed.spans.Span attribute)
clean() (distributed.scheduler.WorkerState method)
clear() (distributed.as_completed method)
(distributed.Event method)
Client (class in distributed)
client_heartbeat() (distributed.scheduler.Scheduler method)
client_key (distributed.scheduler.ClientState attribute)
client_releases_keys() (distributed.scheduler.Scheduler method)
client_send() (distributed.scheduler.Scheduler method)
ClientState (class in distributed.scheduler)
close() (distributed.Client method)
(distributed.comm.Comm method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.nanny.Nanny method)
(distributed.scheduler.Scheduler method)
(distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
close_gracefully() (distributed.nanny.Nanny method)
(distributed.worker.Worker method)
close_worker() (distributed.scheduler.Scheduler method)
closed() (distributed.comm.Comm method)
code (distributed.spans.Span property)
coerce_address() (distributed.scheduler.Scheduler method)
coerce_hostname() (distributed.scheduler.Scheduler method)
collect_digests() (distributed.spans.SpansWorkerExtension method)
collections_to_dsk() (distributed.Client static method)
coming_from (distributed.worker_state_machine.TaskState attribute)
Comm (class in distributed.comm)
compute() (distributed.Client method)
CondaInstall (class in distributed.diagnostics.plugin)
connect() (in module distributed.comm)
constrained (distributed.worker_state_machine.WorkerState attribute)
contact_address (distributed.comm.core.Listener property)
count() (distributed.as_completed method)
cumulative_worker_metrics (distributed.spans.Span property)
current() (distributed.Client class method)
D
dashboard_link (distributed.Client property)
dask_deserialize() (in module distributed.protocol.serialize)
dask_serialize() (in module distributed.protocol.serialize)
data (distributed.worker.Worker property)
(distributed.worker_state_machine.WorkerState attribute)
data_needed (distributed.worker_state_machine.WorkerState attribute)
decide_worker() (in module distributed.scheduler)
decide_worker_non_rootish() (distributed.scheduler.Scheduler method)
decide_worker_rootish_queuing_disabled() (distributed.scheduler.Scheduler method)
decide_worker_rootish_queuing_enabled() (distributed.scheduler.Scheduler method)
delete() (distributed.Variable method)
delete_worker_data() (distributed.scheduler.Scheduler method)
dependencies (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
dependents (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
deserialize() (in module distributed.protocol.serialize)
digest_metric() (distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
(in module distributed.metrics.context_meter)
done (distributed.spans.Span property)
(distributed.worker_state_machine.TaskState attribute)
done() (distributed.active_memory_manager.RetireWorker method)
(distributed.Future method)
dump_cluster_state() (distributed.Client method)
dump_cluster_state_to_url() (distributed.scheduler.Scheduler method)
duration (distributed.spans.Span property)
(distributed.worker_state_machine.TaskState attribute)
E
enqueued (distributed.spans.Span attribute)
Environ (class in distributed.diagnostics.plugin)
erred_on (distributed.scheduler.TaskState attribute)
Event (class in distributed)
evict() (distributed.spill.ManualEvictProto method)
exception (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
exception() (distributed.Future method)
exception_blame (distributed.scheduler.TaskState attribute)
exception_text (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
execute() (distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
executed_count (distributed.worker_state_machine.WorkerState attribute)
executing (distributed.scheduler.WorkerState attribute)
(distributed.worker_state_machine.WorkerState attribute)
executing_count (distributed.worker_state_machine.WorkerState property)
executor (distributed.Future property)
extra (distributed.scheduler.WorkerState attribute)
extra_info (distributed.comm.Comm property)
F
fast (distributed.spill.ManualEvictProto property)
feed() (distributed.scheduler.Scheduler method)
fetch_count (distributed.worker_state_machine.WorkerState attribute)
find_by_tags() (distributed.spans.SpansSchedulerExtension method)
finished() (distributed.scheduler.Scheduler method)
fire_and_forget() (in module distributed)
forward_logging() (distributed.Client method)
from_dict() (distributed.worker_state_machine.StateMachineEvent static method)
from_name() (distributed.SpecCluster class method)
Future (class in distributed)
futures_of() (distributed.Client method)
(in module distributed)
G
gather() (distributed.Client method)
(distributed.scheduler.Scheduler method)
(distributed.worker.Worker method)
gather_dep() (distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
gather_on_worker() (distributed.scheduler.Scheduler method)
generation (distributed.worker_state_machine.WorkerState attribute)
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_cluster_state() (distributed.scheduler.Scheduler method)
get_comm_cost() (distributed.scheduler.Scheduler method)
get_connection_args() (distributed.security.Security method)
get_connection_counters() (distributed.scheduler.Scheduler method)
get_connector() (distributed.comm.registry.Backend method)
get_current_task() (distributed.worker.Worker method)
get_dataset() (distributed.Client method)
get_events() (distributed.Client method)
get_executor() (distributed.Client 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_logs() (distributed.scheduler.Scheduler method)
get_metadata() (distributed.Client method)
get_scheduler_logs() (distributed.Client method)
get_story() (distributed.scheduler.Scheduler method)
get_task_duration() (distributed.scheduler.Scheduler method)
get_task_metadata (class in distributed)
get_task_stream (class in distributed)
get_task_stream() (distributed.Client method)
get_tls_config_for_role() (distributed.security.Security method)
get_value() (distributed.Semaphore 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)
group (distributed.scheduler.TaskState attribute)
group_key (distributed.scheduler.TaskState attribute)
groups (distributed.spans.Span attribute)
H
handle_comm() (distributed.scheduler.Scheduler method)
handle_long_running() (distributed.scheduler.Scheduler method)
handle_request_refresh_who_has() (distributed.scheduler.Scheduler method)
handle_stimulus() (distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
(distributed.worker_state_machine.WorkerState method)
handle_worker() (distributed.scheduler.Scheduler method)
handshake_configuration() (distributed.comm.Comm static method)
handshake_info() (distributed.comm.Comm method)
has_lost_dependencies (distributed.scheduler.TaskState attribute)
has_ready() (distributed.as_completed method)
has_what (distributed.scheduler.WorkerState property)
(distributed.worker_state_machine.WorkerState attribute)
has_what() (distributed.Client method)
heartbeat() (distributed.spans.SpansSchedulerExtension method)
(distributed.spans.SpansWorkerExtension method)
host (distributed.scheduler.Scheduler property)
host_restrictions (distributed.scheduler.TaskState attribute)
I
id (distributed.spans.Span attribute)
identity() (distributed.scheduler.Scheduler method)
in_flight_tasks (distributed.worker_state_machine.WorkerState attribute)
in_flight_tasks_count (distributed.worker_state_machine.WorkerState property)
in_flight_workers (distributed.worker_state_machine.WorkerState attribute)
incoming_comms_active (distributed.scheduler.Scheduler property)
incoming_comms_open (distributed.scheduler.Scheduler property)
InstallPlugin (class in distributed.diagnostics.plugin)
instantiate() (distributed.nanny.Nanny method)
Instruction (class in distributed.worker_state_machine)
interval (distributed.active_memory_manager.ActiveMemoryManagerExtension attribute)
is_empty() (distributed.as_completed method)
is_idle (distributed.scheduler.Scheduler property)
is_rootish() (distributed.scheduler.Scheduler method)
is_set() (distributed.Event method)
K
key (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
kill() (distributed.nanny.Nanny method)
L
last_seen (distributed.scheduler.ClientState attribute)
(distributed.scheduler.WorkerState attribute)
list_datasets() (distributed.Client method)
listen() (in module distributed.comm)
listen_address (distributed.comm.core.Listener property)
(distributed.scheduler.Scheduler property)
Listener (class in distributed.comm.core)
local_address (distributed.comm.Comm property)
LocalCluster (class in distributed)
Lock (class in distributed)
Log (class in distributed.utils)
log (distributed.worker_state_machine.WorkerState attribute)
log_event() (distributed.Client method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.nanny.Nanny method)
(distributed.scheduler.Scheduler method)
(distributed.worker.Worker method)
Logs (class in distributed.utils)
long_running (distributed.scheduler.WorkerState attribute)
(distributed.worker_state_machine.WorkerState attribute)
loop (distributed.deploy.Adaptive property)
loose_restrictions (distributed.scheduler.TaskState attribute)
M
ManualEvictProto (class in distributed.spill)
map() (distributed.Client method)
match() (distributed.worker_state_machine.Instruction class method)
measure (distributed.active_memory_manager.ActiveMemoryManagerExtension attribute)
memory (distributed.scheduler.WorkerState property)
memory_limit (distributed.scheduler.WorkerState attribute)
MemorySampler (class in distributed.diagnostics)
MemoryState (class in distributed.scheduler)
memray_scheduler() (in module distributed.diagnostics.memray)
memray_workers() (in module distributed.diagnostics.memray)
merge() (distributed.spans.Span static method)
merge_all() (distributed.spans.SpansSchedulerExtension method)
merge_by_tags() (distributed.spans.SpansSchedulerExtension method)
metadata (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
meter() (in module distributed.metrics.context_meter)
missing_dep_flight (distributed.worker_state_machine.WorkerState attribute)
MultiLock (class in distributed)
N
name (distributed.spans.Span attribute)
Nanny (class in distributed.nanny)
nanny (distributed.scheduler.WorkerState attribute)
NannyPlugin (class in distributed.diagnostics.plugin)
nbytes (distributed.scheduler.TaskState attribute)
(distributed.scheduler.WorkerState attribute)
(distributed.worker_state_machine.TaskState attribute)
(distributed.worker_state_machine.WorkerState attribute)
nbytes() (distributed.Client method)
nbytes_total (distributed.spans.Span property)
ncores() (distributed.Client method)
needs_what (distributed.scheduler.WorkerState attribute)
new_task() (distributed.scheduler.Scheduler method)
new_worker_spec() (distributed.SpecCluster method)
next (distributed.worker_state_machine.TaskState attribute)
next_batch() (distributed.as_completed method)
normalize_address() (in module distributed.comm)
normalize_collection() (distributed.Client method)
nthreads (distributed.scheduler.WorkerState attribute)
(distributed.worker_state_machine.WorkerState attribute)
nthreads() (distributed.Client method)
nthreads_intervals (distributed.spans.Span property)
O
observe_tasks() (distributed.spans.SpansSchedulerExtension method)
op (distributed.active_memory_manager.Suggestion attribute)
outgoing_comms_active (distributed.scheduler.Scheduler property)
outgoing_comms_open (distributed.scheduler.Scheduler property)
P
parse_address() (in module distributed.comm)
peer_address (distributed.comm.Comm property)
pending (distributed.active_memory_manager.ActiveMemoryManagerExtension attribute)
performance_report (class in distributed)
persist() (distributed.Client method)
PipInstall (class in distributed.diagnostics.plugin)
plot() (distributed.diagnostics.MemorySampler method)
plugins (distributed.worker_state_machine.WorkerState attribute)
policies (distributed.active_memory_manager.ActiveMemoryManagerExtension attribute)
port (distributed.scheduler.Scheduler property)
prefix (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
previous (distributed.worker_state_machine.TaskState attribute)
print() (in module distributed)
priority (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
processing (distributed.scheduler.WorkerState attribute)
processing() (distributed.Client method)
processing_on (distributed.scheduler.TaskState attribute)
profile() (distributed.Client method)
progress() (in module distributed.diagnostics.progressbar)
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)
ready (distributed.worker_state_machine.WorkerState attribute)
rebalance() (distributed.Client method)
(distributed.scheduler.Scheduler method)
recommendations() (distributed.deploy.Adaptive method)
recreate_error_locally() (distributed.recreate_tasks.ReplayTaskClient method)
recreate_task_locally() (distributed.recreate_tasks.ReplayTaskClient method)
ReduceReplicas (class in distributed.active_memory_manager)
register_generic() (in module distributed.protocol.serialize)
register_nanny_plugin() (distributed.scheduler.Scheduler method)
register_plugin() (distributed.Client method)
register_scheduler_plugin() (distributed.Client method)
(distributed.scheduler.Scheduler method)
register_worker_callbacks() (distributed.Client method)
register_worker_plugin() (distributed.Client method)
(distributed.scheduler.Scheduler method)
rejoin() (in module distributed)
release() (distributed.Future method)
(distributed.Lock method)
(distributed.MultiLock method)
(distributed.Semaphore method)
remove_all_replicas() (distributed.scheduler.Scheduler method)
remove_client() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
remove_from_processing() (distributed.scheduler.WorkerState method)
remove_plugin() (distributed.scheduler.Scheduler method)
remove_replica() (distributed.scheduler.Scheduler method)
(distributed.scheduler.WorkerState method)
remove_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
ReplayTaskClient (class in distributed.recreate_tasks)
replicate() (distributed.Client method)
(distributed.scheduler.Scheduler method)
report() (distributed.scheduler.Scheduler method)
request_acquire_replicas() (distributed.scheduler.Scheduler method)
request_remove_replicas() (distributed.scheduler.Scheduler method)
Reschedule (class in distributed)
resolve_address() (distributed.comm.registry.Backend method)
(in module distributed.comm)
resource_restrictions (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
resources (distributed.scheduler.WorkerState attribute)
restart() (distributed.Client method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
restart_workers() (distributed.Client method)
(distributed.scheduler.Scheduler method)
result() (distributed.Future method)
retire_workers() (distributed.Client method)
(distributed.scheduler.Scheduler method)
RetireWorker (class in distributed.active_memory_manager)
retries (distributed.scheduler.TaskState attribute)
retry() (distributed.Client method)
(distributed.Future method)
retry_busy_worker_later() (distributed.worker.Worker method)
(distributed.worker_state_machine.BaseWorker method)
rng (distributed.worker_state_machine.WorkerState attribute)
root_spans (distributed.spans.SpansSchedulerExtension attribute)
rpc (class in distributed.core)
run() (distributed.active_memory_manager.ActiveMemoryManagerPolicy method)
(distributed.Client method)
run_function() (distributed.scheduler.Scheduler method)
run_id (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
run_on_scheduler() (distributed.Client method)
run_once() (distributed.active_memory_manager.ActiveMemoryManagerExtension method)
(distributed.active_memory_manager.AMMClientProxy method)
run_spec (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
running (distributed.active_memory_manager.ActiveMemoryManagerExtension property)
(distributed.worker_state_machine.WorkerState attribute)
running() (distributed.active_memory_manager.AMMClientProxy method)
S
same_host (distributed.comm.Comm property)
sample() (distributed.diagnostics.MemorySampler method)
scale() (distributed.SpecCluster method)
scale_up() (distributed.SpecCluster method)
scatter() (distributed.Client method)
(distributed.scheduler.Scheduler method)
Scheduler (class in distributed.scheduler)
scheduler (distributed.active_memory_manager.ActiveMemoryManagerExtension attribute)
scheduler_info() (distributed.Client method)
SchedulerPlugin (class in distributed.diagnostics.plugin)
SchedulerUploadFile (class in distributed.diagnostics.plugin)
secede() (in module distributed)
Security (class in distributed.security)
Semaphore (class in distributed)
send_all() (distributed.scheduler.Scheduler method)
send_task_to_worker() (distributed.scheduler.Scheduler method)
serialize() (in module distributed.protocol.serialize)
Server (class in distributed.core)
set() (distributed.Event method)
(distributed.Variable method)
set_metadata() (distributed.Client method)
setup() (distributed.diagnostics.plugin.NannyPlugin method)
(distributed.diagnostics.plugin.WorkerPlugin method)
shutdown() (distributed.Client method)
Span (class in distributed.spans)
span() (in module distributed)
span_id (distributed.worker_state_machine.TaskState attribute)
spans (distributed.spans.SpansSchedulerExtension attribute)
spans_search_by_name (distributed.spans.SpansSchedulerExtension attribute)
spans_search_by_tag (distributed.spans.SpansSchedulerExtension attribute)
SpansSchedulerExtension (class in distributed.spans)
SpansWorkerExtension (class in distributed.spans)
SpecCluster (class in distributed)
start (distributed.spans.Span property)
start() (distributed.active_memory_manager.ActiveMemoryManagerExtension method)
(distributed.active_memory_manager.AMMClientProxy method)
(distributed.Client method)
(distributed.comm.core.Listener method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
start_http_server() (distributed.scheduler.Scheduler method)
start_periodic_callbacks() (distributed.scheduler.Scheduler method)
start_time (distributed.worker_state_machine.TaskState attribute)
start_unsafe() (distributed.nanny.Nanny method)
(distributed.scheduler.Scheduler method)
(distributed.worker.Worker method)
startstops (distributed.worker_state_machine.TaskState attribute)
state (distributed.scheduler.TaskState property)
(distributed.worker_state_machine.TaskState attribute)
StateMachineEvent (class in distributed.worker_state_machine)
states (distributed.spans.Span property)
status (distributed.Future property)
(distributed.scheduler.WorkerState attribute)
stimulus_cancel() (distributed.scheduler.Scheduler method)
stimulus_id (distributed.worker_state_machine.StateMachineEvent attribute)
stimulus_log (distributed.worker_state_machine.WorkerState attribute)
stimulus_queue_slots_maybe_opened() (distributed.scheduler.Scheduler method)
stimulus_story() (distributed.worker_state_machine.WorkerState method)
stimulus_task_erred() (distributed.scheduler.Scheduler method)
stimulus_task_finished() (distributed.scheduler.Scheduler method)
stop (distributed.spans.Span property)
stop() (distributed.active_memory_manager.ActiveMemoryManagerExtension method)
(distributed.active_memory_manager.AMMClientProxy method)
(distributed.comm.core.Listener method)
stop_time (distributed.worker_state_machine.TaskState attribute)
story() (distributed.Client method)
(distributed.scheduler.Scheduler method)
(distributed.worker_state_machine.WorkerState method)
submit() (distributed.Client method)
subscribe_topic() (distributed.Client method)
Suggestion (class in distributed.active_memory_manager)
suspicious (distributed.scheduler.TaskState attribute)
suspicious_count (distributed.worker_state_machine.TaskState attribute)
T
target() (distributed.deploy.Adaptive method)
task_counter (distributed.worker_state_machine.WorkerState attribute)
tasks (distributed.worker_state_machine.WorkerState attribute)
TaskState (class in distributed.scheduler)
(class in distributed.worker_state_machine)
teardown() (distributed.diagnostics.plugin.NannyPlugin method)
(distributed.diagnostics.plugin.WorkerPlugin method)
temporary() (distributed.security.Security class method)
threads (distributed.worker_state_machine.WorkerState attribute)
to_loggable() (distributed.worker_state_machine.StateMachineEvent method)
to_pandas() (distributed.diagnostics.MemorySampler method)
total_resources (distributed.worker_state_machine.WorkerState attribute)
traceback (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
traceback() (distributed.Future method)
traceback_text (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
transfer_incoming_bytes (distributed.worker_state_machine.WorkerState attribute)
transfer_incoming_bytes_limit (distributed.worker_state_machine.WorkerState attribute)
transfer_incoming_bytes_throttle_threshold (distributed.worker_state_machine.WorkerState attribute)
transfer_incoming_count (distributed.worker_state_machine.WorkerState property)
transfer_incoming_count_limit (distributed.worker_state_machine.WorkerState attribute)
transfer_incoming_count_total (distributed.worker_state_machine.WorkerState attribute)
transfer_message_bytes_limit (distributed.worker_state_machine.WorkerState attribute)
transfer_outgoing_bytes (distributed.worker.Worker attribute)
transfer_outgoing_bytes_total (distributed.worker.Worker attribute)
transfer_outgoing_count (distributed.worker.Worker attribute)
transfer_outgoing_count_total (distributed.worker.Worker attribute)
transition() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.diagnostics.plugin.WorkerPlugin method)
(distributed.scheduler.Scheduler method)
transition_counter (distributed.worker_state_machine.WorkerState attribute)
transition_counter_max (distributed.worker_state_machine.WorkerState attribute)
transitions() (distributed.scheduler.Scheduler method)
traverse_groups() (distributed.spans.Span method)
traverse_spans() (distributed.spans.Span method)
trigger_profile() (distributed.worker.Worker method)
ts (distributed.active_memory_manager.Suggestion attribute)
type (distributed.Future property)
(distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
U
unforward_logging() (distributed.Client method)
unparse_address() (in module distributed.comm)
unpublish_dataset() (distributed.Client method)
unregister_nanny_plugin() (distributed.scheduler.Scheduler method)
unregister_scheduler_plugin() (distributed.Client method)
(distributed.scheduler.Scheduler method)
unregister_worker_plugin() (distributed.Client method)
(distributed.scheduler.Scheduler method)
unsubscribe_topic() (distributed.Client method)
update() (distributed.as_completed method)
update_data() (distributed.scheduler.Scheduler method)
update_graph() (distributed.diagnostics.plugin.SchedulerPlugin method)
upload_file() (distributed.Client method)
UploadDirectory (class in distributed.diagnostics.plugin)
UploadFile (class in distributed.diagnostics.plugin)
used_resources (distributed.scheduler.WorkerState attribute)
V
valid_workers() (distributed.scheduler.Scheduler method)
validate (distributed.worker_state_machine.WorkerState attribute)
Variable (class in distributed)
versions (distributed.scheduler.ClientState attribute)
(distributed.scheduler.WorkerState attribute)
W
wait() (distributed.Event method)
(in module distributed)
wait_for_workers() (distributed.Client method)
waiters (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
waiting (distributed.worker_state_machine.WorkerState attribute)
waiting_for_data (distributed.worker_state_machine.TaskState attribute)
waiting_on (distributed.scheduler.TaskState attribute)
wants_what (distributed.scheduler.ClientState attribute)
warn() (in module distributed)
who_has (distributed.scheduler.TaskState attribute)
(distributed.worker_state_machine.TaskState attribute)
who_has() (distributed.Client method)
who_wants (distributed.scheduler.TaskState attribute)
Worker (class in distributed.worker)
worker_address (distributed.worker.Worker property)
worker_client() (in module distributed)
worker_objective() (distributed.scheduler.Scheduler method)
worker_restrictions (distributed.scheduler.TaskState attribute)
worker_send() (distributed.scheduler.Scheduler method)
WorkerPlugin (class in distributed.diagnostics.plugin)
workers_list() (distributed.scheduler.Scheduler method)
workers_memory (distributed.active_memory_manager.ActiveMemoryManagerExtension attribute)
workers_to_close() (distributed.deploy.Adaptive method)
(distributed.scheduler.Scheduler method)
WorkerState (class in distributed.scheduler)
(class in distributed.worker_state_machine)
write() (distributed.comm.Comm method)
write_scheduler_file() (distributed.Client method)