Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▸ cli
▸ client
▸ comm
▸ compatibility
▸ config
▸ core
▸ counter
▸ dashboard
▸ deploy
▾ diagnostics
▸ eventstream
▸ graph_layout
▸ nvml
▸ plugin
▸ progress
▸ progress_stream
▸ progressbar
▸ task_stream
▾ tests
▸ test_eventstream
▸ test_graph_layout
▸ test_nvml
▸ test_progress
▸ test_progress_stream
▸ test_progressbar
▸ test_scheduler_plugin
▾ test_task_stream
▸ test_widgets
▸ test_worker_plugin
▸ websocket
▸ 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_task_stream
distributed
.
diagnostics
.
tests
.
test_task_stream
source
link
Functions
▷
def
test_client_sync
(
client
)
source
link
▷
def
test_get_task_stream_save
(
client, tmpdir
)
source
link
Generated by
nedoc
v0.9 at 2020-12-29 14:05