Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▸ cli
▸ client
▸ comm
▸ compatibility
▸ config
▸ core
▸ counter
▸ dashboard
▾ deploy
▸ adaptive
▸ adaptive_core
▸ cluster
▸ local
▸ old_ssh
▾ spec
class
NoOpAwaitable
class
ProcessInterface
class
SpecCluster
▸ ssh
▸ tests
▸ utils_test
▸ diagnostics
▸ diskutils
▸ event
▸ http
▸ lock
▸ locket
▸ metrics
▸ nanny
▸ node
▸ preloading
▸ process
▸ proctitle
▸ profile
▸ protocol
▸ publish
▸ pubsub
▸ pytest_resourceleaks
▸ queues
▸ recreate_exceptions
▸ scheduler
▸ security
▸ semaphore
▸ sizeof
▸ stealing
▸ system
▸ system_monitor
▸ tests
▸ threadpoolexecutor
▸ utils
▸ utils_comm
▸ utils_perf
▸ utils_test
▸ variable
▸ versions
▸ worker
▸ worker_client
Module spec
distributed
.
deploy
.
spec
source
link
Classes
class
NoOpAwaitable
An awaitable object that always returns None.
class
ProcessInterface
An interface for Scheduler and Worker processes for use in SpecCluster
class
SpecCluster
Cluster that requires a full specification of workers
Functions
▶
def
close_clusters
(
)
@atexit.register
@atexit.register
def
close_clusters(
)
source
link
Reexports
Imported in
distributed.deploy.tests.test_spec_cluster
.
Generated by
nedoc
v0.9 at 2020-12-29 14:05