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_metadata() (distributed.spans.Span 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) aliases (distributed.scheduler.Scheduler attribute) 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) clients (distributed.scheduler.Scheduler attribute) 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) coming_from (distributed.worker_state_machine.TaskState attribute) Comm (class in distributed.comm) computations (distributed.scheduler.Scheduler attribute) 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) E enqueued (distributed.spans.Span attribute) Environ (class in distributed.diagnostics.plugin) erred_on (distributed.scheduler.TaskState attribute) erred_tasks (distributed.scheduler.Scheduler 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_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) 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) (distributed.scheduler.WorkerState attribute) host_restrictions (distributed.scheduler.TaskState attribute) I id (distributed.spans.Span attribute) identity() (distributed.scheduler.Scheduler method) idle (distributed.scheduler.Scheduler attribute) idle_task_count (distributed.scheduler.Scheduler attribute) 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) MEMORY_REBALANCE_HALF_GAP (distributed.scheduler.Scheduler attribute) MEMORY_REBALANCE_MEASURE (distributed.scheduler.Scheduler attribute) MEMORY_REBALANCE_RECIPIENT_MAX (distributed.scheduler.Scheduler attribute) MEMORY_REBALANCE_SENDER_MIN (distributed.scheduler.Scheduler attribute) MEMORY_RECENT_TO_OLD_TIME (distributed.scheduler.Scheduler 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 n_tasks (distributed.scheduler.Scheduler attribute) 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 property) (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) queued (distributed.scheduler.Scheduler attribute) 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.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) replicated_tasks (distributed.scheduler.Scheduler attribute) 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.Scheduler attribute) (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.scheduler.Scheduler attribute) (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) saturated (distributed.scheduler.Scheduler attribute) 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.deploy.Adaptive attribute) (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.scheduler.Scheduler attribute) (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_memory (distributed.scheduler.Scheduler attribute) total_nthreads (distributed.scheduler.Scheduler attribute) total_nthreads_history (distributed.scheduler.Scheduler attribute) 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.scheduler.Scheduler attribute) (distributed.worker_state_machine.WorkerState attribute) transition_counter_max (distributed.scheduler.Scheduler attribute) (distributed.worker_state_machine.WorkerState attribute) transition_log (distributed.scheduler.Scheduler 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) UNKNOWN_TASK_DURATION (distributed.scheduler.Scheduler attribute) 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) unrunnable (distributed.scheduler.Scheduler attribute) 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) valid_workers_downscaling() (distributed.diagnostics.plugin.SchedulerPlugin method) validate (distributed.scheduler.Scheduler attribute) (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_SATURATION (distributed.scheduler.Scheduler attribute) worker_send() (distributed.scheduler.Scheduler method) WorkerPlugin (class in distributed.diagnostics.plugin) workers (distributed.scheduler.Scheduler attribute) 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)
