切换导航

索引

A

abort() (distributed.comm.Comm 方法) acquire() (distributed.Lock 方法) (distributed.MultiLock 方法) (distributed.Semaphore 方法) active_cpu_seconds (distributed.spans.Span property) ActiveMemoryManagerExtension (distributed.active_memory_manager 中的类) ActiveMemoryManagerPolicy (distributed.active_memory_manager 中的类) actor (distributed.scheduler.TaskState 属性) actors (distributed.scheduler.WorkerState 属性) (distributed.worker_state_machine.WorkerState 属性) adapt() (distributed.SpecCluster 方法) Adaptive (distributed.deploy 中的类) adaptive_target() (distributed.scheduler.Scheduler 方法) add() (distributed.as_completed 方法) add_client() (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.scheduler.Scheduler 方法) add_dependency() (distributed.scheduler.TaskState 方法) add_done_callback() (distributed.Future 方法) add_keys() (distributed.scheduler.Scheduler 方法) add_metadata() (distributed.spans.Span 方法)

add_plugin() (distributed.scheduler.Scheduler 方法) add_replica() (distributed.scheduler.Scheduler 方法) (distributed.scheduler.WorkerState 方法) add_to_processing() (distributed.scheduler.WorkerState 方法) add_worker() (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.scheduler.Scheduler 方法) address (distributed.scheduler.Scheduler property) (distributed.scheduler.WorkerState 属性) (distributed.worker_state_machine.WorkerState 属性) 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 方法) AMMClientProxy (distributed.active_memory_manager 中的类) annotation (distributed.spans.Span property) annotations (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) as_completed (distributed 中的类) as_current() (distributed.Client 方法) available_resources (distributed.worker_state_machine.WorkerState 属性)

B

Backend (distributed.comm.registry 中的类) BaseWorker (distributed.worker_state_machine 中的类) batched_send() (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法) batches() (distributed.as_completed 方法)

before_close() (distributed.diagnostics.plugin.SchedulerPlugin 方法) benchmark_hardware() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) broadcast() (distributed.scheduler.Scheduler 方法) bulk_schedule_unrunnable_after_adding_worker() (distributed.scheduler.Scheduler 方法) busy_workers (distributed.worker_state_machine.WorkerState 属性)

C

call_stack() (distributed.Client 方法) cancel() (distributed.Client 方法) (distributed.Future 方法) cancelled() (distributed.Future 方法) candidates (distributed.active_memory_manager.Suggestion 属性) check_idle_saturated() (distributed.scheduler.Scheduler 方法) children (distributed.spans.Span 属性) clean() (distributed.scheduler.WorkerState 方法) clear() (distributed.as_completed 方法) (distributed.Event 方法) Client (distributed 中的类) client_heartbeat() (distributed.scheduler.Scheduler 方法) client_key (distributed.scheduler.ClientState 属性) client_releases_keys() (distributed.scheduler.Scheduler 方法) client_send() (distributed.scheduler.Scheduler 方法) ClientState (distributed.scheduler 中的类) close() (distributed.Client 方法) (distributed.comm.Comm 方法) (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.nanny.Nanny 方法) (distributed.scheduler.Scheduler 方法) (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法)

close_gracefully() (distributed.nanny.Nanny 方法) (distributed.worker.Worker 方法) close_worker() (distributed.scheduler.Scheduler 方法) closed() (distributed.comm.Comm 方法) code (distributed.spans.Span property) coerce_address() (distributed.scheduler.Scheduler 方法) coerce_hostname() (distributed.scheduler.Scheduler 方法) collections_to_dsk() (distributed.Client 静态方法) coming_from (distributed.worker_state_machine.TaskState 属性) Comm (distributed.comm 中的类) compute() (distributed.Client 方法) CondaInstall (distributed.diagnostics.plugin 中的类) connect() (在 distributed.comm 模块中) constrained (distributed.worker_state_machine.WorkerState 属性) contact_address (distributed.comm.core.Listener property) count() (distributed.as_completed 方法) cumulative_worker_metrics (distributed.spans.Span property) current() (distributed.Client 类方法)

D

dashboard_link (distributed.Client property) dask_deserialize() (在 distributed.protocol.serialize 模块中) dask_serialize() (在 distributed.protocol.serialize 模块中) data (distributed.worker.Worker property) (distributed.worker_state_machine.WorkerState 属性) data_needed (distributed.worker_state_machine.WorkerState 属性) decide_worker() (在 distributed.scheduler 模块中) decide_worker_non_rootish() (distributed.scheduler.Scheduler 方法) decide_worker_rootish_queuing_disabled() (distributed.scheduler.Scheduler 方法) decide_worker_rootish_queuing_enabled() (distributed.scheduler.Scheduler 方法) delete() (distributed.Variable 方法) delete_worker_data() (distributed.scheduler.Scheduler 方法) dependencies (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性)

dependents (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) deserialize() (在 distributed.protocol.serialize 模块中) digest_metric() (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法) (在 distributed.metrics.context_meter 模块中) done (distributed.spans.Span property) (distributed.worker_state_machine.TaskState 属性) done() (distributed.active_memory_manager.RetireWorker 方法) (distributed.Future 方法) dump_cluster_state() (distributed.Client 方法) dump_cluster_state_to_url() (distributed.scheduler.Scheduler 方法) duration (distributed.spans.Span property) (distributed.worker_state_machine.TaskState 属性)

E

enqueued (distributed.spans.Span 属性) Environ (distributed.diagnostics.plugin 中的类) erred_on (distributed.scheduler.TaskState 属性) Event (distributed 中的类) evict() (distributed.spill.ManualEvictProto 方法) exception (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) exception() (distributed.Future 方法) exception_blame (distributed.scheduler.TaskState 属性) exception_text (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性)

execute() (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法) executed_count (distributed.worker_state_machine.WorkerState 属性) executing (distributed.scheduler.WorkerState 属性) (distributed.worker_state_machine.WorkerState 属性) executing_count (distributed.worker_state_machine.WorkerState property) executor (distributed.Future property) extra (distributed.scheduler.WorkerState 属性) extra_info (distributed.comm.Comm property)

F

fast (distributed.spill.ManualEvictProto property) feed() (distributed.scheduler.Scheduler 方法) fetch_count (distributed.worker_state_machine.WorkerState 属性) find_by_tags() (distributed.spans.SpansSchedulerExtension 方法) finished() (distributed.scheduler.Scheduler 方法) fire_and_forget() (在 distributed 模块中)

forward_logging() (distributed.Client 方法) from_dict() (distributed.worker_state_machine.StateMachineEvent 静态方法) from_name() (distributed.SpecCluster 类方法) Future (distributed 中的类) futures_of() (distributed.Client 方法) (在 distributed 模块中)

G

gather() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) (distributed.worker.Worker 方法) gather_dep() (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法) gather_on_worker() (distributed.scheduler.Scheduler 方法) generation (distributed.worker_state_machine.WorkerState 属性) get() (distributed.Client 方法) (distributed.Queue 方法) (distributed.Variable 方法) get_address_host() (distributed.comm.registry.Backend 方法) (在 distributed.comm 模块中) get_address_host_port() (distributed.comm.registry.Backend 方法) get_client() (在 distributed 模块中) get_cluster_state() (distributed.scheduler.Scheduler 方法) get_comm_cost() (distributed.scheduler.Scheduler 方法) get_connection_args() (distributed.security.Security 方法) get_connection_counters() (distributed.scheduler.Scheduler 方法) get_connector() (distributed.comm.registry.Backend 方法) get_current_task() (distributed.worker.Worker 方法) get_dataset() (distributed.Client 方法)

get_events() (distributed.Client 方法) get_executor() (distributed.Client 方法) get_listen_args() (distributed.security.Security 方法) get_listener() (distributed.comm.registry.Backend 方法) get_local_address_for() (distributed.comm.registry.Backend 方法) get_logs() (distributed.scheduler.Scheduler 方法) get_metadata() (distributed.Client 方法) get_scheduler_logs() (distributed.Client 方法) get_story() (distributed.scheduler.Scheduler 方法) get_task_duration() (distributed.scheduler.Scheduler 方法) get_task_metadata (distributed 中的类) get_task_stream (distributed 中的类) get_task_stream() (distributed.Client 方法) get_tls_config_for_role() (distributed.security.Security 方法) get_value() (distributed.Semaphore 方法) get_versions() (distributed.Client 方法) get_worker() (在 distributed 模块中) get_worker_logs() (distributed.Client 方法) get_worker_service_addr() (distributed.scheduler.Scheduler 方法) group (distributed.scheduler.TaskState 属性) groups (distributed.spans.Span 属性)

H

handle_comm() (distributed.scheduler.Scheduler 方法) handle_long_running() (distributed.scheduler.Scheduler 方法) handle_request_refresh_who_has() (distributed.scheduler.Scheduler 方法) handle_stimulus() (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法) (distributed.worker_state_machine.WorkerState 方法) handle_worker() (distributed.scheduler.Scheduler 方法) handshake_configuration() (distributed.comm.Comm 静态方法) handshake_info() (distributed.comm.Comm 方法)

has_lost_dependencies (distributed.scheduler.TaskState 属性) has_ready() (distributed.as_completed 方法) has_what (distributed.scheduler.WorkerState property) (distributed.worker_state_machine.WorkerState 属性) has_what() (distributed.Client 方法) heartbeat() (distributed.spans.SpansSchedulerExtension 方法) (distributed.spans.SpansWorkerExtension 方法) host (distributed.scheduler.Scheduler property) host_restrictions (distributed.scheduler.TaskState 属性)

I

id (distributed.spans.Span 属性) identity() (distributed.scheduler.Scheduler 方法) in_flight_tasks (distributed.worker_state_machine.WorkerState 属性) in_flight_tasks_count (distributed.worker_state_machine.WorkerState property) in_flight_workers (distributed.worker_state_machine.WorkerState 属性) incoming_comms_active (distributed.scheduler.Scheduler property) incoming_comms_open (distributed.scheduler.Scheduler property)

InstallPlugin (distributed.diagnostics.plugin 中的类) instantiate() (distributed.nanny.Nanny 方法) Instruction (distributed.worker_state_machine 中的类) interval (distributed.active_memory_manager.ActiveMemoryManagerExtension 属性) is_empty() (distributed.as_completed 方法) is_idle (distributed.scheduler.Scheduler property) is_rootish() (distributed.scheduler.Scheduler 方法) is_set() (distributed.Event 方法)

K

key (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性)

kill() (distributed.nanny.Nanny 方法)

L

last_seen (distributed.scheduler.ClientState 属性) (distributed.scheduler.WorkerState 属性) list_datasets() (distributed.Client 方法) listen() (在 distributed.comm 模块中) listen_address (distributed.comm.core.Listener property) (distributed.scheduler.Scheduler property) Listener (distributed.comm.core 中的类) local_address (distributed.comm.Comm property) LocalCluster (distributed 中的类) Lock (distributed 中的类) Log (distributed.utils 中的类)

log (distributed.worker_state_machine.WorkerState 属性) log_event() (distributed.Client 方法) (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.nanny.Nanny 方法) (distributed.scheduler.Scheduler 方法) (distributed.worker.Worker 方法) Logs (distributed.utils 中的类) long_running (distributed.scheduler.WorkerState 属性) (distributed.worker_state_machine.WorkerState 属性) loop (distributed.deploy.Adaptive property) loose_restrictions (distributed.scheduler.TaskState 属性)

M

ManualEvictProto (distributed.spill 中的类) map() (distributed.Client 方法) match() (distributed.worker_state_machine.Instruction 类方法) measure (distributed.active_memory_manager.ActiveMemoryManagerExtension 属性) memory (distributed.scheduler.WorkerState property) memory_limit (distributed.scheduler.WorkerState 属性) MemorySampler (distributed.diagnostics 中的类) MemoryState (distributed.scheduler 中的类) memray_scheduler() (在 distributed.diagnostics.memray 模块中)

memray_workers() (在 distributed.diagnostics.memray 模块中) merge() (distributed.spans.Span 静态方法) merge_all() (distributed.spans.SpansSchedulerExtension 方法) merge_by_tags() (distributed.spans.SpansSchedulerExtension 方法) metadata (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) meter() (在 distributed.metrics.context_meter 模块中) missing_dep_flight (distributed.worker_state_machine.WorkerState 属性) MultiLock (distributed 中的类)

N

name (distributed.spans.Span 属性) Nanny (distributed.nanny 中的类) nanny (distributed.scheduler.WorkerState 属性) NannyPlugin (distributed.diagnostics.plugin 中的类) nbytes (distributed.scheduler.TaskState 属性) (distributed.scheduler.WorkerState 属性) (distributed.worker_state_machine.TaskState 属性) (distributed.worker_state_machine.WorkerState 属性) nbytes() (distributed.Client 方法) nbytes_total (distributed.spans.Span property) ncores() (distributed.Client 方法)

needs_what (distributed.scheduler.WorkerState 属性) new_task() (distributed.scheduler.Scheduler 方法) new_worker_spec() (distributed.SpecCluster 方法) next (distributed.worker_state_machine.TaskState 属性) next_batch() (distributed.as_completed 方法) normalize_address() (在 distributed.comm 模块中) normalize_collection() (distributed.Client 方法) nthreads (distributed.scheduler.WorkerState 属性) (distributed.worker_state_machine.WorkerState 属性) nthreads() (distributed.Client 方法) nthreads_intervals (distributed.spans.Span property)

O

observe_tasks() (distributed.spans.SpansSchedulerExtension 方法) op (distributed.active_memory_manager.Suggestion 属性)

outgoing_comms_active (distributed.scheduler.Scheduler property) outgoing_comms_open (distributed.scheduler.Scheduler property)

P

parse_address() (在 distributed.comm 模块中) peer_address (distributed.comm.Comm property) pending (distributed.active_memory_manager.ActiveMemoryManagerExtension 属性) performance_report (distributed 中的类) persist() (distributed.Client 方法) PipInstall (distributed.diagnostics.plugin 中的类) plot() (distributed.diagnostics.MemorySampler 方法) plugins (distributed.worker_state_machine.WorkerState 属性) policies (distributed.active_memory_manager.ActiveMemoryManagerExtension 属性) port (distributed.scheduler.Scheduler property) prefix (distributed.scheduler.TaskState property) (distributed.worker_state_machine.TaskState 属性) previous (distributed.worker_state_machine.TaskState 属性)

print() (在 distributed 模块中) priority (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) processing (distributed.scheduler.WorkerState 属性) processing() (distributed.Client 方法) processing_on (distributed.scheduler.TaskState 属性) profile() (distributed.Client 方法) progress() (在 distributed.diagnostics.progressbar 模块中) proxy() (distributed.scheduler.Scheduler 方法) publish_dataset() (distributed.Client 方法) put() (distributed.Queue 方法) Python 提高建议 PEP 3148

Q

qsize() (distributed.Queue 方法)

Queue (distributed 中的类)

R

read() (distributed.comm.Comm 方法) ready (distributed.worker_state_machine.WorkerState 属性) rebalance() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) recommendations() (distributed.deploy.Adaptive 方法) recreate_error_locally() (distributed.recreate_tasks.ReplayTaskClient 方法) recreate_task_locally() (distributed.recreate_tasks.ReplayTaskClient 方法) ReduceReplicas (distributed.active_memory_manager 中的类) register_generic() (在 distributed.protocol.serialize 模块中) register_nanny_plugin() (distributed.scheduler.Scheduler 方法) register_plugin() (distributed.Client 方法) register_scheduler_plugin() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) register_worker_callbacks() (distributed.Client 方法) register_worker_plugin() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) rejoin() (在 distributed 模块中) release() (distributed.Future 方法) (distributed.MultiLock 方法) (distributed.Semaphore 方法) remove_all_replicas() (distributed.scheduler.Scheduler 方法) remove_client() (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.scheduler.Scheduler 方法) remove_from_processing() (distributed.scheduler.WorkerState 方法) remove_plugin() (distributed.scheduler.Scheduler 方法) remove_replica() (distributed.scheduler.Scheduler 方法) (distributed.scheduler.WorkerState 方法) remove_worker() (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.scheduler.Scheduler 方法) ReplayTaskClient (distributed.recreate_tasks 中的类) replicate() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) report() (distributed.scheduler.Scheduler 方法) request_acquire_replicas() (distributed.scheduler.Scheduler 方法) request_remove_replicas() (distributed.scheduler.Scheduler 方法)

Reschedule (distributed 中的类) resolve_address() (distributed.comm.registry.Backend 方法) (在 distributed.comm 模块中) resource_restrictions (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) resources (distributed.scheduler.WorkerState 属性) restart() (distributed.Client 方法) (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.scheduler.Scheduler 方法) restart_workers() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) result() (distributed.Future 方法) retire_workers() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) RetireWorker (distributed.active_memory_manager 中的类) retries (distributed.scheduler.TaskState 属性) retry() (distributed.Client 方法) (distributed.Future 方法) retry_busy_worker_later() (distributed.worker.Worker 方法) (distributed.worker_state_machine.BaseWorker 方法) rng (distributed.worker_state_machine.WorkerState 属性) root_spans (distributed.spans.SpansSchedulerExtension 属性) rpc (distributed.core 中的类) run() (distributed.active_memory_manager.ActiveMemoryManagerPolicy 方法) (distributed.Client 方法) run_function() (distributed.scheduler.Scheduler 方法) run_id (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) run_on_scheduler() (distributed.Client 方法) run_once() (distributed.active_memory_manager.ActiveMemoryManagerExtension 方法) (distributed.active_memory_manager.AMMClientProxy 方法) run_spec (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) running (distributed.active_memory_manager.ActiveMemoryManagerExtension property) (distributed.worker_state_machine.WorkerState 属性) running() (distributed.active_memory_manager.AMMClientProxy 方法)

S

same_host (distributed.comm.Comm property) sample() (distributed.diagnostics.MemorySampler 方法) scale() (distributed.SpecCluster 方法) scale_up() (distributed.SpecCluster 方法) scatter() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) scheduler (distributed.active_memory_manager.ActiveMemoryManagerExtension 属性) Scheduler (distributed.scheduler 中的类) scheduler_info() (distributed.Client 方法) SchedulerPlugin (distributed.diagnostics.plugin 中的类) SchedulerUploadFile (distributed.diagnostics.plugin 中的类) secede() (在 distributed 模块中) Security (distributed.security 中的类) Semaphore (distributed 中的类) send_all() (distributed.scheduler.Scheduler 方法) send_task_to_worker() (distributed.scheduler.Scheduler 方法) serialize() (在 distributed.protocol.serialize 模块中) Server (distributed.core 中的类) set() (distributed.Event 方法) (distributed.Variable 方法) set_metadata() (distributed.Client 方法) setup() (distributed.diagnostics.plugin.NannyPlugin 方法) (distributed.diagnostics.plugin.WorkerPlugin 方法) shutdown() (distributed.Client 方法) Span (distributed.spans 中的类) span() (在 distributed 模块中) span_id (distributed.worker_state_machine.TaskState 属性) spans (distributed.spans.SpansSchedulerExtension 属性) spans_search_by_name (distributed.spans.SpansSchedulerExtension 属性) spans_search_by_tag (distributed.spans.SpansSchedulerExtension 属性) SpansSchedulerExtension (distributed.spans 中的类) SpansWorkerExtension (distributed.spans 中的类) SpecCluster (distributed 中的类) start (distributed.spans.Span property) start() (distributed.active_memory_manager.ActiveMemoryManagerExtension 方法) (distributed.active_memory_manager.AMMClientProxy 方法) (distributed.Client 方法) (distributed.comm.core.Listener 方法) (distributed.diagnostics.plugin.SchedulerPlugin 方法)

start_http_server() (distributed.scheduler.Scheduler 方法) start_periodic_callbacks() (distributed.scheduler.Scheduler 方法) start_time (distributed.worker_state_machine.TaskState 属性) start_unsafe() (distributed.nanny.Nanny 方法) (distributed.scheduler.Scheduler 方法) (distributed.worker.Worker 方法) startstops (distributed.worker_state_machine.TaskState 属性) state (distributed.deploy.Adaptive 属性) (distributed.scheduler.TaskState property) (distributed.worker_state_machine.TaskState 属性) StateMachineEvent (distributed.worker_state_machine 中的类) states (distributed.spans.Span property) status (distributed.Future property) (distributed.scheduler.WorkerState 属性) stimulus_cancel() (distributed.scheduler.Scheduler 方法) stimulus_id (distributed.worker_state_machine.StateMachineEvent 属性) stimulus_log (distributed.worker_state_machine.WorkerState 属性) stimulus_queue_slots_maybe_opened() (distributed.scheduler.Scheduler 方法) stimulus_story() (distributed.worker_state_machine.WorkerState 方法) stimulus_task_erred() (distributed.scheduler.Scheduler 方法) stimulus_task_finished() (distributed.scheduler.Scheduler 方法) stop (distributed.spans.Span property) stop() (distributed.active_memory_manager.ActiveMemoryManagerExtension 方法) (distributed.active_memory_manager.AMMClientProxy 方法) (distributed.comm.core.Listener 方法) stop_time (distributed.worker_state_machine.TaskState 属性) story() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) (distributed.worker_state_machine.WorkerState 方法) submit() (distributed.Client 方法) subscribe_topic() (distributed.Client 方法) Suggestion (distributed.active_memory_manager 中的类) suspicious (distributed.scheduler.TaskState 属性) suspicious_count (distributed.worker_state_machine.TaskState 属性)

T

target() (distributed.deploy.Adaptive 方法) task_counter (distributed.worker_state_machine.WorkerState 属性) tasks (distributed.worker_state_machine.WorkerState 属性) TaskState (distributed.scheduler 中的类) (distributed.worker_state_machine 中的类) teardown() (distributed.diagnostics.plugin.NannyPlugin 方法) (distributed.diagnostics.plugin.WorkerPlugin 方法) temporary() (distributed.security.Security 类方法) threads (distributed.worker_state_machine.WorkerState 属性) to_loggable() (distributed.worker_state_machine.StateMachineEvent 方法) to_pandas() (distributed.diagnostics.MemorySampler 方法) total_resources (distributed.worker_state_machine.WorkerState 属性) traceback (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) traceback() (distributed.Future 方法) traceback_text (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) transfer_incoming_bytes (distributed.worker_state_machine.WorkerState 属性) transfer_incoming_bytes_limit (distributed.worker_state_machine.WorkerState 属性) transfer_incoming_bytes_throttle_threshold (distributed.worker_state_machine.WorkerState 属性)

transfer_incoming_count (distributed.worker_state_machine.WorkerState property) transfer_incoming_count_limit (distributed.worker_state_machine.WorkerState 属性) transfer_incoming_count_total (distributed.worker_state_machine.WorkerState 属性) transfer_message_bytes_limit (distributed.worker_state_machine.WorkerState 属性) transfer_outgoing_bytes (distributed.worker.Worker 属性) transfer_outgoing_bytes_total (distributed.worker.Worker 属性) transfer_outgoing_count (distributed.worker.Worker 属性) transfer_outgoing_count_total (distributed.worker.Worker 属性) transition() (distributed.diagnostics.plugin.SchedulerPlugin 方法) (distributed.diagnostics.plugin.WorkerPlugin 方法) (distributed.scheduler.Scheduler 方法) transition_counter (distributed.worker_state_machine.WorkerState 属性) transition_counter_max (distributed.worker_state_machine.WorkerState 属性) transitions() (distributed.scheduler.Scheduler 方法) traverse_groups() (distributed.spans.Span 方法) traverse_spans() (distributed.spans.Span 方法) trigger_profile() (distributed.worker.Worker 方法) ts (distributed.active_memory_manager.Suggestion 属性) type (distributed.Future property) (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性)

U

unforward_logging() (distributed.Client 方法) unparse_address() (在 distributed.comm 模块中) unpublish_dataset() (distributed.Client 方法) unregister_nanny_plugin() (distributed.scheduler.Scheduler 方法) unregister_scheduler_plugin() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法) unregister_worker_plugin() (distributed.Client 方法) (distributed.scheduler.Scheduler 方法)

unsubscribe_topic() (distributed.Client 方法) update() (distributed.as_completed 方法) update_data() (distributed.scheduler.Scheduler 方法) update_graph() (distributed.diagnostics.plugin.SchedulerPlugin 方法) upload_file() (distributed.Client 方法) UploadDirectory (distributed.diagnostics.plugin 中的类) UploadFile (distributed.diagnostics.plugin 中的类) used_resources (distributed.scheduler.WorkerState 属性)

V

valid_workers() (distributed.scheduler.Scheduler 方法) valid_workers_downscaling() (distributed.diagnostics.plugin.SchedulerPlugin 方法) validate (distributed.worker_state_machine.WorkerState 属性)

Variable (distributed 中的类) versions (distributed.scheduler.ClientState 属性) (distributed.scheduler.WorkerState 属性)

W

wait() (distributed.Event 方法) (在 distributed 模块中) wait_for_workers() (distributed.Client 方法) waiters (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) waiting (distributed.worker_state_machine.WorkerState 属性) waiting_for_data (distributed.worker_state_machine.TaskState 属性) waiting_on (distributed.scheduler.TaskState 属性) wants_what (distributed.scheduler.ClientState 属性) warn() (在 distributed 模块中) who_has (distributed.scheduler.TaskState 属性) (distributed.worker_state_machine.TaskState 属性) who_has() (distributed.Client 方法) who_wants (distributed.scheduler.TaskState 属性)

Worker (distributed.worker 中的类) worker_address (distributed.worker.Worker property) worker_client() (在 distributed 模块中) worker_objective() (distributed.scheduler.Scheduler 方法) worker_restrictions (distributed.scheduler.TaskState 属性) worker_send() (distributed.scheduler.Scheduler 方法) WorkerPlugin (distributed.diagnostics.plugin 中的类) workers_list() (distributed.scheduler.Scheduler 方法) workers_memory (distributed.active_memory_manager.ActiveMemoryManagerExtension 属性) workers_to_close() (distributed.deploy.Adaptive 方法) (distributed.scheduler.Scheduler 方法) WorkerState (distributed.scheduler 中的类) (distributed.worker_state_machine 中的类) write() (distributed.comm.Comm 方法) write_scheduler_file() (distributed.Client 方法)