Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▾ cli
▸ dask_scheduler
▸ dask_spec
▸ dask_ssh
▸ dask_worker
▾ tests
▸ test_dask_scheduler
▸ test_dask_spec
▸ test_dask_ssh
▾ test_dask_worker
▸ test_tls_cli
▸ 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 test_dask_worker
distributed
.
cli
.
tests
.
test_dask_worker
source
link
Functions
▷
def
test_bokeh_deprecation
(
)
source
link
▷
def
test_contact_listen_address
(
loop, nanny, listen_address
)
3 decorators
@pytest.mark.skipif( not sys.platform.startswith("linux"), reason="Need 127.0.0.2 to mean localhost" )
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
@pytest.mark.parametrize( "listen_address", ["tcp://0.0.0.0:39837", "tcp://127.0.0.2:39837"] )
def
test_contact_listen_address(
loop,
nanny,
listen_address,
)
source
link
▷
def
test_dashboard_non_standard_ports
(
loop
)
source
link
▷
def
test_local_directory
(
loop, nanny
)
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
def
test_local_directory(
loop,
nanny,
)
source
link
▷
def
test_memory_limit
(
loop
)
source
link
▷
def
test_nanny_worker_port_range
(
loop
)
source
link
▷
def
test_nanny_worker_port_range_too_many_workers_raises
(
loop
)
source
link
▷
def
test_nanny_worker_ports
(
loop
)
source
link
▷
def
test_no_nanny
(
loop
)
source
link
▷
def
test_no_reconnect
(
nanny, loop
)
@pytest.mark.slow
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
@pytest.mark.slow
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
def
test_no_reconnect(
nanny,
loop,
)
source
link
▷
def
test_nprocs_expands_name
(
loop
)
source
link
▷
def
test_nprocs_negative
(
loop
)
source
link
▷
def
test_nprocs_requires_nanny
(
loop
)
source
link
▷
def
test_resources
(
loop
)
source
link
▷
def
test_respect_host_listen_address
(
loop, nanny, host
)
3 decorators
@pytest.mark.skipif( not sys.platform.startswith("linux"), reason="Need 127.0.0.2 to mean localhost" )
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
@pytest.mark.parametrize("host", ["127.0.0.2", "0.0.0.0"])
def
test_respect_host_listen_address(
loop,
nanny,
host,
)
source
link
▷
def
test_scheduler_address_env
(
loop, monkeypatch
)
source
link
▷
def
test_scheduler_file
(
loop, nanny
)
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
def
test_scheduler_file(
loop,
nanny,
)
source
link
▷
def
test_version_option
(
)
source
link
▷
def
test_worker_timeout
(
no_nanny
)
@pytest.mark.slow
@pytest.mark.parametrize("no_nanny", [True, False])
@pytest.mark.slow
@pytest.mark.parametrize("no_nanny", [True, False])
def
test_worker_timeout(
no_nanny
)
source
link
Generated by
nedoc
v0.9 at 2020-12-29 14:05