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
▸ process
▸ proctitle
▸ profile
▸ protocol
▸ publish
▸ pubsub
▸ pytest_resourceleaks
▸ queues
▸ recreate_exceptions
▸ scheduler
▸ security
▸ semaphore
▸ sizeof
▸ stealing
▸ system
▸ system_monitor
▾ tests
▸ make_tls_certs
▾ test_actor
class
Counter
class
List
class
ParameterServer
class
UsesCounter
▸ test_as_completed
▸ test_asyncprocess
▸ test_batched
▸ test_client
▸ test_client_executor
▸ test_client_loop
▸ test_collections
▸ test_config
▸ test_core
▸ test_counter
▸ test_diskutils
▸ test_events
▸ test_failed_workers
▸ test_ipython
▸ test_locks
▸ test_metrics
▸ test_nanny
▸ test_preload
▸ test_priorities
▸ test_profile
▸ test_publish
▸ test_pubsub
▸ test_queues
▸ test_resources
▸ test_scheduler
▸ test_security
▸ test_semaphore
▸ test_sizeof
▸ test_spec
▸ test_steal
▸ test_stress
▸ test_system
▸ test_system_monitor
▸ test_threadpoolexecutor
▸ test_tls_functional
▸ test_utils
▸ test_utils_comm
▸ test_utils_perf
▸ test_utils_test
▸ test_variable
▸ test_versions
▸ test_worker
▸ test_worker_client
▸ threadpoolexecutor
▸ utils
▸ utils_comm
▸ utils_perf
▸ utils_test
▸ variable
▸ versions
▸ worker
▸ worker_client
Module test_actor
distributed
.
tests
.
test_actor
source
link
Classes
class
Counter
class
List
class
ParameterServer
class
UsesCounter
Functions
▷
def
test_client_actions
(
direct_to_workers
)
@pytest.mark.parametrize("direct_to_workers", [True, False])
@pytest.mark.parametrize("direct_to_workers", [True, False])
def
test_client_actions(
direct_to_workers
)
source
link
▷
def
test_compute_sync
(
client
)
source
link
▷
def
test_one_thread_deadlock
(
)
source
link
▷
def
test_sync
(
client
)
source
link
▷
def
test_worker_actions
(
separate_thread
)
@pytest.mark.parametrize("separate_thread", [False, True])
@pytest.mark.parametrize("separate_thread", [False, True])
def
test_worker_actions(
separate_thread
)
source
link
Generated by
nedoc
v0.9 at 2020-12-29 14:05