Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▾ cli
▸ dask_scheduler
▸ dask_spec
▸ dask_ssh
▸ dask_worker
▸ tests
▾ utils
▸ client
▸ comm
▸ compatibility
▸ config
▸ core
▸ counter
▸ dashboard
▸ deploy
▸ 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 utils
distributed
.
cli
.
utils
source
link
Functions
▶
def
check_python_3
(
)
Ensures that the environment is good for unicode on Python 3.
source
link
Reexports
Imported in
distributed.cli.dask_scheduler
.
Imported in
distributed.cli.dask_ssh
.
Imported in
distributed.cli.dask_worker
.
▶
def
install_signal_handlers
(
loop=None, cleanup=None
)
Install global signal handlers to halt the Tornado IOLoop in case of a SIGINT or SIGTERM. *cleanup* is an optional callback called, before the loop stops, with a single signal number argument.
source
link
Reexports
Imported in
distributed.cli.dask_scheduler
.
Imported in
distributed.cli.dask_worker
.
Generated by
nedoc
v0.9 at 2020-12-29 14:05