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
▸ test_as_completed
▸ test_asyncprocess
▸ test_batched
▸ test_client
▸ test_client_executor
▸ test_client_loop
▸ test_collections
▸ test_config
▾ test_core
class
CountedObject
class
MyServer
▸ 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_core
distributed
.
tests
.
test_core
source
link
Classes
class
CountedObject
A class which counts the number of live instances.
class
MyServer
Functions
▷
def
echo
(
comm, x
)
source
link
▷
def
echo_no_serialize
(
comm, x
)
source
link
▷
def
echo_serialize
(
comm, x
)
source
link
▷
def
stream_div
(
comm=None, x=None, y=None
)
source
link
▷
def
test_coerce_to_address
(
)
source
link
▷
def
test_compression
(
compression, serialize, loop
)
@pytest.mark.parametrize("compression", list(compressions))
@pytest.mark.parametrize("serialize", [echo_serialize, echo_no_serialize])
@pytest.mark.parametrize("compression", list(compressions))
@pytest.mark.parametrize("serialize", [echo_serialize, echo_no_serialize])
def
test_compression(
compression,
serialize,
loop,
)
source
link
▷
def
test_rpc_serialization
(
loop
)
source
link
▷
def
test_server
(
loop
)
Simple Server test.
source
link
▷
def
test_server_assign_assign_enum_is_quiet
(
)
That would be the default in user code
source
link
▷
def
test_server_raises_on_blocked_handlers
(
loop
)
source
link
▷
def
test_server_status_assign_non_variant_raises
(
)
source
link
▷
def
test_server_status_assign_with_variant_raises_in_tests
(
)
That would be the default in user code
source
link
▷
def
test_server_status_assign_with_variant_warns
(
)
source
link
▷
def
test_server_status_compare_enum_is_quiet
(
)
That would be the default in user code
source
link
▷
def
test_server_status_compare_non_variant_raises
(
)
source
link
▷
def
test_server_status_compare_with_variant_raises_in_tests
(
)
That would be the default in user code
source
link
▷
def
test_server_status_compare_with_variant_warns
(
)
source
link
▷
def
test_server_status_is_always_enum
(
)
Assignments with strings get converted to corresponding Enum variant
source
link
Generated by
nedoc
v0.9 at 2020-12-29 14:05