Module test_client

Classes

• class BadlySerializedObject
• class CountSerialization
• class FatallySerializedObject
• class MyException

Functions

• ▷ def assert_dict_key_equal(expected, actual)

  source link
• ▷ def assert_no_data_loss(scheduler)

  source link
• ▷ def long_running_client_connection(address)

  source link
• ▷ def test_Future_exception_sync(c)

  source link
• ▷ def test_Future_exception_sync_2(loop, capsys)

  source link
• ▷ def test_Future_release_sync(c)

  source link
• ▷ def test_as_completed_batches(c, with_results) @pytest.mark.parametrize("with_results", [True, False])

  @pytest.mark.parametrize("with_results", [True, False])
  def test_as_completed_batches(

  c,

  with_results,

  )

  source link
• ▷ def test_as_completed_list(c)

  source link
• ▷ def test_as_completed_next_batch(c)

  source link
• ▷ def test_as_completed_results(c)

  source link
• ▷ def test_as_current_is_thread_local(s)

  source link
• ▷ def test_async_with(loop)

  source link
• ▷ def test_auto_normalize_collection_sync(c)

  source link
• ▷ def test_bad_address() @pytest.mark.skipif("True", reason="because")

  @pytest.mark.skipif("True", reason="because")
  def test_bad_address()

  source link
• ▷ def test_broadcast(c, s, a, b)

  source link
• ▷ def test_cancel(c)

  source link
• ▷ def test_client_async_before_loop_starts()

  source link
• ▷ def test_client_connectionpool_semaphore_loop(s, a, b)

  source link
• ▷ def test_client_doesnt_close_given_loop(loop_in_thread, s, a, b)

  source link
• ▷ def test_client_num_fds(loop) @pytest.mark.skipif(WINDOWS, reason="num_fds not supported on windows")

  @pytest.mark.skipif(WINDOWS, reason="num_fds not supported on windows")
  def test_client_num_fds(loop)

  source link
• ▷ def test_client_replicate_sync(c)

  source link
• ▷ def test_client_repr_closed_sync(loop)

  source link
• ▷ def test_client_sync_with_async_def(loop)

  source link
• ▷ def test_close_idempotent(c)

  source link
• ▷ def test_current(s, a, b)

  source link
• ▷ def test_dashboard_link(loop, monkeypatch)

  source link
• ▷ def test_default_get()

  source link
• ▷ def test_diagnostic_nbytes_sync(c)

  source link
• ▷ def test_diagnostic_ui(loop)

  source link
• ▷ def test_direct_sync(c)

  source link
• ▷ def test_direct_to_workers(s, loop)

  source link
• ▷ def test_directed_scatter_sync(c, s, a, b, loop)

  source link
• ▷ def test_dynamic_workloads_sync(c)

  source link
• ▷ def test_dynamic_workloads_sync_random(c) @pytest.mark.slow

  @pytest.mark.slow
  def test_dynamic_workloads_sync_random(c)

  source link
• ▷ def test_futures_of_class()

  source link
• ▷ def test_gather_sync(c)

  source link
• ▷ def test_get_client_no_cluster()

  source link
• ▷ def test_get_client_sync(c, s, a, b)

  source link
• ▷ def test_get_processing_sync(c, s, a, b)

  source link
• ▷ def test_get_restrictions()

  source link
• ▷ def test_get_returns_early(c) @nodebug

  @nodebug
  def test_get_returns_early(c)

  source link
• ▷ def test_get_stops_work_after_error(c)

  source link
• ▷ def test_get_sync(c)

  source link
• ▷ def test_get_sync_optimize_graph_passes_through(c)

  source link
• ▷ def test_get_versions(c)

  source link
• ▷ def test_get_with_error_sync(c)

  source link
• ▷ def test_global_clients(loop)

  source link
• ▷ def test_informative_error_on_cluster_type()

  source link
• ▷ def test_no_future_references(c)

  source link
• ▷ def test_no_threads_lingering()

  source link
• ▷ def test_normalize_collection_with_released_futures(c) @pytest.mark.slow

  @pytest.mark.slow
  def test_normalize_collection_with_released_futures(c)

  source link
• ▷ def test_open_close_many_workers(loop, worker, count, repeat) 4 decorators

  @pytest.mark.slow
  @pytest.mark.skipif(WINDOWS, reason="num_fds not supported on windows")
  @pytest.mark.skipif(sys.version_info < (3, 7), reason="TODO: intermittent failures")
  @pytest.mark.parametrize("worker,count,repeat", [(Worker, 100, 5), (Nanny, 10, 20)])
  def test_open_close_many_workers(

  loop,

  worker,

  count,

  repeat,

  )

  source link
• ▷ def test_persist(c)

  source link
• ▷ def test_persist_get_sync(c)

  source link
• ▷ def test_quiet_client_close(loop)

  source link
• ▷ def test_quiet_client_close_when_cluster_is_closed_before_client(loop) @pytest.mark.slow

  @pytest.mark.slow
  def test_quiet_client_close_when_cluster_is_closed_before_client(loop)

  source link
• ▷ def test_quiet_quit_when_cluster_leaves(loop_in_thread)

  source link
• ▷ def test_rebalance_sync(c, s, a, b)

  source link
• ▷ def test_reconnect(loop) @pytest.mark.slow

  @pytest.mark.slow
  def test_reconnect(loop)

  source link
• ▷ def test_recreate_error_not_error(c)

  source link
• ▷ def test_recreate_error_sync(c)

  source link
• ▷ def test_repr(loop)

  source link
• ▷ def test_repr_sync(c)

  source link
• ▷ def test_retries_get(c)

  source link
• ▷ def test_run_coroutine_sync(c, s, a, b)

  source link
• ▷ def test_run_exception(c)

  source link
• ▷ def test_run_sync(c, s, a, b)

  source link
• ▷ def test_scatter_gather_sync(c, direct, broadcast) @pytest.mark.parametrize("direct", [True, False]) @pytest.mark.parametrize("broadcast", [True, False])

  @pytest.mark.parametrize("direct", [True, False])
  @pytest.mark.parametrize("broadcast", [True, False])
  def test_scatter_gather_sync(

  c,

  direct,

  broadcast,

  )

  source link
• ▷ def test_scheduler_info(c)

  source link
• ▷ def test_serialize_collections_of_futures_sync(c)

  source link
• ▷ def test_short_tracebacks(loop, c)

  source link
• ▷ def test_start_is_idempotent(c)

  source link
• ▷ def test_startup_close_startup_sync(loop)

  source link
• ▷ def test_sync_compute(c)

  source link
• ▷ def test_sync_exceptions(c)

  source link
• ▷ def test_thread(c)

  source link
• ▷ def test_threaded_get_within_distributed(c)

  source link
• ▷ def test_threadsafe(c)

  source link
• ▷ def test_threadsafe_compute(c) @pytest.mark.slow

  @pytest.mark.slow
  def test_threadsafe_compute(c)

  source link
• ▷ def test_threadsafe_get(c) @pytest.mark.slow

  @pytest.mark.slow
  def test_threadsafe_get(c)

  source link
• ▷ def test_traceback_sync(c)

  source link
• ▷ def test_turn_off_pickle(direct) @pytest.mark.parametrize("direct", [True, False])

  @pytest.mark.parametrize("direct", [True, False])
  def test_turn_off_pickle(direct)

  source link
• ▷ def test_upload_file_exception_sync(c)

  source link
• ▷ def test_upload_file_sync(c)

  source link
• ▷ def test_use_synchronous_client_in_async_context(loop, c)

  source link
• ▷ def test_wait_informative_error_for_timeouts(c)

  source link
• ▷ def test_wait_sync(c)

  source link
• ▷ def test_warn_executor(loop, s, a, b)

  source link
• ▷ def test_write_scheduler_file(c)

  source link

Generated by nedoc v0.9 at 2020-12-29 14:05