Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▸ cli
▸ client
▸ comm
▸ compatibility
▸ config
▸ core
▸ counter
▸ dashboard
▸ deploy
▸ diagnostics
▸ diskutils
▸ event
▸ http
▸ lock
▸ locket
▸ metrics
▸ nanny
▸ node
▾ preloading
class
Preload
▸ 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 preloading
distributed
.
preloading
source
link
Classes
class
Preload
Manage state for setup/teardown of a preload module
Functions
▷
def
is_webaddress
(
s: str
) -> bool
source
link
▶
def
process_preloads
(
dask_server, preload: List[str], preload_argv: List[List], ...
) -> List[Preload]
def
process_preloads(
dask_server,
preload: List[str],
preload_argv: List[List],
file_dir: str =
None
,
) -> List[Preload]
source
link
▶
def
validate_preload_argv
(
ctx, param, value
)
Click option callback providing validation of preload subcommand arguments.
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