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
▸ arrow
▸ compression
▸ core
▸ cuda
▸ cupy
▸ h5py
▸ highlevelgraph
▸ keras
▸ netcdf4
▸ numba
▸ numpy
▸ pickle
▸ rmm
▸ scipy
▸ serialize
▸ sparse
▾ tests
▸ test_arrow
▸ test_collection
▸ test_collection_cuda
▸ test_cupy
▸ test_h5py
▸ test_highlevelgraph
▸ test_keras
▸ test_netcdf4
▸ test_numba
▸ test_numpy
▸ test_pandas
▸ test_pickle
▾ test_protocol
▸ test_protocol_utils
▸ test_rmm
▸ test_scipy
▸ test_serialize
▸ test_sparse
▸ test_torch
▸ torch
▸ utils
▸ 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_protocol
distributed
.
protocol
.
tests
.
test_protocol
source
link
Functions
▷
def
eq_frames
(
a, b
)
source
link
▷
def
test_compression_1
(
)
source
link
▷
def
test_compression_2
(
)
source
link
▷
def
test_compression_without_deserialization
(
)
source
link
▷
def
test_dumps_loads_Serialize
(
)
source
link
▷
def
test_dumps_loads_Serialized
(
)
source
link
▷
def
test_large_bytes
(
)
source
link
▷
def
test_large_messages
(
)
@pytest.mark.slow
@pytest.mark.slow
def
test_large_messages(
)
source
link
▷
def
test_large_messages_map
(
)
source
link
▷
def
test_loads_deserialize_False
(
)
source
link
▷
def
test_loads_without_deserialization_avoids_compression
(
)
source
link
▷
def
test_maybe_compress
(
lib, compression
)
@pytest.mark.parametrize( "lib,compression", [(None, None), ("zlib", "zlib"), ("lz4", "lz4"), ("zstandard", "zstd")], )
@pytest.mark.parametrize( "lib,compression", [(None, None), ("zlib", "zlib"), ("lz4", "lz4"), ("zstandard", "zstd")], )
def
test_maybe_compress(
lib,
compression,
)
source
link
▷
def
test_maybe_compress_memoryviews
(
)
source
link
▷
def
test_maybe_compress_sample
(
)
source
link
▷
def
test_protocol
(
)
source
link
▷
def
test_small
(
)
source
link
▷
def
test_small_and_big
(
)
source
link
Generated by
nedoc
v0.9 at 2020-12-29 14:05