Module test_local

Classes

• class LocalTest
• class MyWorker

Functions

• ▷ def test_Client_kwargs(loop)

  source link
• ▷ def test_Client_solo(loop)

  source link
• ▷ def test_Client_twice(loop)

  source link
• ▷ def test_Client_unused_kwargs_with_address(loop)

  source link
• ▷ def test_Client_unused_kwargs_with_cluster(loop)

  source link
• ▷ def test_Client_with_local(loop)

  source link
• ▷ def test_adapt(loop)

  source link
• ▷ def test_adapt_then_manual(loop)

  We can revert from adaptive, back to manual

  source link
• ▷ def test_asynchronous_property(loop)

  source link
• ▷ def test_blocks_until_full(loop)

  source link
• ▷ def test_bokeh(loop, processes) @pytest.mark.parametrize("processes", [True, False])

  @pytest.mark.parametrize("processes", [True, False])
  def test_bokeh(

  loop,

  processes,

  )

  source link
• ▷ def test_cleanup()

  source link
• ▷ def test_client_cluster_synchronous(loop)

  source link
• ▷ def test_close_twice()

  source link
• ▷ def test_death_timeout_raises(loop)

  source link
• ▷ def test_default_process_thread_breakdown()

  source link
• ▷ def test_dont_select_closed_worker()

  source link
• ▷ def test_io_loop_periodic_callbacks(loop)

  source link
• ▷ def test_ipywidgets(loop)

  source link
• ▷ def test_local_cluster_supports_blocked_handlers(loop)

  source link
• ▷ def test_local_tls(loop, temporary) @pytest.mark.parametrize("temporary", [True, False])

  @pytest.mark.parametrize("temporary", [True, False])
  def test_local_tls(

  loop,

  temporary,

  )

  source link
• ▷ def test_local_tls_restart(loop)

  source link
• ▷ def test_logging()

  Workers and scheduler have logs even when silenced

  source link
• ▷ def test_memory(loop, n_workers) @pytest.mark.parametrize("n_workers", [None, 3])

  @pytest.mark.parametrize("n_workers", [None, 3])
  def test_memory(

  loop,

  n_workers,

  )

  source link
• ▷ def test_memory_nanny(loop, n_workers) @pytest.mark.parametrize("n_workers", [None, 3])

  @pytest.mark.parametrize("n_workers", [None, 3])
  def test_memory_nanny(

  loop,

  n_workers,

  )

  source link
• ▷ def test_move_unserializable_data()

  Test that unserializable data is still fine to transfer over inproc transports.

  source link
• ▷ def test_no_ipywidgets(loop, monkeypatch)

  source link
• ▷ def test_only_local_access(loop)

  source link
• ▷ def test_procs()

  source link
• ▷ def test_protocol_inproc(loop)

  source link
• ▷ def test_protocol_ip(loop) @pytest.mark.skipif( not sys.platform.startswith("linux"), reason="Need 127.0.0.2 to mean localhost" )

  @pytest.mark.skipif( not sys.platform.startswith("linux"), reason="Need 127.0.0.2 to mean localhost" )
  def test_protocol_ip(loop)

  source link
• ▷ def test_protocol_tcp(loop)

  source link
• ▷ def test_remote_access(loop)

  source link
• ▷ def test_repeated()

  source link
• ▷ def test_scale(loop)

  Directly calling scale both up and down works as expected

  source link
• ▷ def test_silent_startup() @pytest.mark.xfail( sys.version_info >= (3, 8) and LooseVersion(tornado.version) < "6.0.3", reason="Known issue with Python 3.8 and Tornado < 6.0.3. " "See https://github.com/tornadoweb/tornado/pull/2683.", strict=True, )

  @pytest.mark.xfail( sys.version_info >= (3, 8) and LooseVersion(tornado.version) < "6.0.3", reason="Known issue with Python 3.8 and Tornado < 6.0.3. " "See https://github.com/tornadoweb/tornado/pull/2683.", strict=True, )
  def test_silent_startup()

  source link
• ▷ def test_simple(loop)

  source link
• ▷ def test_starts_up_sync(loop)

  source link
• ▷ def test_transports_inproc()

  Test the transport chosen by LocalCluster depending on arguments.

  source link
• ▷ def test_transports_tcp()

  source link
• ▷ def test_transports_tcp_port()

  source link
• ▷ def test_worker_class_nanny(loop)

  source link
• ▷ def test_worker_class_worker(loop)

  source link

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