Module utils_test

Classes

• class TaskStateMetadataPlugin
  WorkPlugin to populate TaskState.metadata

Functions

• ▶ def a(cluster_fixture) @pytest.fixture

  @pytest.fixture
  def a(cluster_fixture)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_worker.
• ▶ def b(cluster_fixture) @pytest.fixture

  @pytest.fixture
  def b(cluster_fixture)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_worker.
• ▶ def bump_rlimit(limit, desired)

  source link

  Reexports

  • Imported in distributed.tests.test_stress.
• ▶ def captured_handler(handler) @contextmanager

  Capture output from the given logging.StreamHandler.

  @contextmanager
  def captured_handler(handler)

  source link

  Reexports

  • Imported in distributed.tests.test_config.
• ▶ def captured_logger(logger, level=logging.INFO, propagate=None) @contextmanager

  Capture output from the given Logger.

  @contextmanager
  def captured_logger(

  logger,

  level=logging.INFO,

  propagate=None,

  )

  source link

  Reexports

  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.tests.test_batched.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_config.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.tests.test_diskutils.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_nanny.
  • Imported in distributed.tests.test_preload.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_sizeof.
  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_utils.
  • Imported in distributed.tests.test_utils_perf.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_worker.
• ▷ def check_active_rpc(loop, active_rpc_timeout=1) @contextmanager

  @contextmanager
  def check_active_rpc(

  loop,

  active_rpc_timeout=1,

  )

  source link
• ▷ def check_instances() @contextmanager

  @contextmanager
  def check_instances()

  source link
• ▷ def check_process_leak(check=True) @contextmanager

  @contextmanager
  def check_process_leak(check=True)

  source link
• ▷ def check_thread_leak() @contextmanager

  @contextmanager
  def check_thread_leak()

  source link
• ▶ def clean(threads=not WINDOWS, instances=True, timeout=1, processes=True) @contextmanager

  @contextmanager
  def clean(

  threads=not WINDOWS,

  instances=True,

  timeout=1,

  processes=True,

  )

  source link

  Reexports

  • Imported in distributed.deploy.tests.test_adaptive.
  • Imported in distributed.deploy.tests.test_local.
• ▶ def cleanup() @pytest.fixture

  @pytest.fixture
  def cleanup()

  source link

  Reexports

  • Imported in distributed.cli.tests.test_dask_spec.
  • Imported in distributed.cli.tests.test_dask_worker.
  • Imported in distributed.comm.tests.test_ucx.
  • Imported in distributed.comm.tests.test_ucx_config.
  • Imported in distributed.deploy.tests.test_adaptive.
  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.deploy.tests.test_slow_adaptive.
  • Imported in distributed.deploy.tests.test_spec_cluster.
  • Imported in distributed.diagnostics.tests.test_scheduler_plugin.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_nanny.
  • Imported in distributed.tests.test_preload.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_tls_functional.
  • Imported in distributed.tests.test_utils_test.
  • Imported in distributed.tests.test_worker.
• ▶ def client(loop, cluster_fixture) @pytest.fixture

  @pytest.fixture
  def client(

  loop,

  cluster_fixture,

  )

  source link

  Reexports

  • Imported in distributed.diagnostics.tests.test_progressbar.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.tests.test_actor.
  • Imported in distributed.tests.test_as_completed.
  • Imported in distributed.tests.test_client as c.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_collections.
  • Imported in distributed.tests.test_events.
  • Imported in distributed.tests.test_locks.
  • Imported in distributed.tests.test_publish.
  • Imported in distributed.tests.test_queues.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_worker.
  • Imported in distributed.tests.test_worker_client.
• ▷ def client_contract_script(tmpdir_factory) @pytest.fixture(scope="session")

  @pytest.fixture(scope="session")
  def client_contract_script(tmpdir_factory)

  source link
• ▶ def client_secondary(loop, cluster_fixture) @pytest.fixture

  @pytest.fixture
  def client_secondary(

  loop,

  cluster_fixture,

  )

  source link

  Reexports

  • Imported in distributed.tests.test_client as c2.
• ▶ def cluster(nworkers=2, nanny=False, worker_kwargs={}, active_rpc_timeout=1, ...) @contextmanager

  @contextmanager
  def cluster(

  nworkers=2,

  nanny=False,

  worker_kwargs={},

  active_rpc_timeout=1,

  disconnect_timeout=3,

  scheduler_kwargs={},

  )

  source link

  Reexports

  • Imported in distributed.tests.test_actor.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_ipython.
  • Imported in distributed.tests.test_preload.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_stress.
  • Imported in distributed.tests.test_utils_test.
• ▶ def cluster_fixture(loop) @pytest.fixture

  @pytest.fixture
  def cluster_fixture(loop)

  source link

  Reexports

  • Imported in distributed.diagnostics.tests.test_progressbar.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.tests.test_actor.
  • Imported in distributed.tests.test_as_completed.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_collections.
  • Imported in distributed.tests.test_events.
  • Imported in distributed.tests.test_locks.
  • Imported in distributed.tests.test_publish.
  • Imported in distributed.tests.test_queues.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_worker.
  • Imported in distributed.tests.test_worker_client.
• ▶ def dec(x)

  source link

  Reexports

  • Imported in distributed.dashboard.tests.test_scheduler_bokeh.
  • Imported in distributed.dashboard.tests.test_worker_bokeh.
  • Imported in distributed.diagnostics.tests.test_progress.
  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_worker.
• ▷ def deep(n)

  source link
• ▶ def div(x, y)

  source link

  Reexports

  • Imported in distributed.dashboard.tests.test_scheduler_bokeh.
  • Imported in distributed.diagnostics.tests.test_eventstream.
  • Imported in distributed.diagnostics.tests.test_progress.
  • Imported in distributed.diagnostics.tests.test_progress_stream.
  • Imported in distributed.diagnostics.tests.test_progressbar.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_queues.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_utils.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_worker.
• ▶ def double(x)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_tls_functional.
  • Imported in distributed.tests.test_worker_client.
• ▶ def gen_cluster(nthreads=[("127.0.0.1", 1), ("127.0.0.1", 2)], ncores=None, ...)

  def gen_cluster(

  nthreads=[("127.0.0.1", 1), ("127.0.0.1", 2)],

  ncores=None,

  scheduler="127.0.0.1",

  timeout=10,

  security=None,

  Worker=Worker,

  client=False,

  scheduler_kwargs={},

  worker_kwargs={},

  client_kwargs={},

  active_rpc_timeout=1,

  config={},

  clean_kwargs={},

  allow_unclosed=False,

  )

  source link

  Reexports

  • Imported in distributed.dashboard.tests.test_components.
  • Imported in distributed.dashboard.tests.test_scheduler_bokeh.
  • Imported in distributed.dashboard.tests.test_worker_bokeh.
  • Imported in distributed.diagnostics.tests.test_eventstream.
  • Imported in distributed.diagnostics.tests.test_graph_layout.
  • Imported in distributed.diagnostics.tests.test_nvml.
  • Imported in distributed.diagnostics.tests.test_progress.
  • Imported in distributed.diagnostics.tests.test_progress_stream.
  • Imported in distributed.diagnostics.tests.test_progressbar.
  • Imported in distributed.diagnostics.tests.test_scheduler_plugin.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.diagnostics.tests.test_worker_plugin.
  • Imported in distributed.http.scheduler.tests.test_scheduler_http.
  • Imported in distributed.http.scheduler.tests.test_semaphore_http.
  • Imported in distributed.http.tests.test_core.
  • Imported in distributed.http.worker.tests.test_worker_http.
  • Imported in distributed.protocol.tests.test_arrow.
  • Imported in distributed.protocol.tests.test_h5py.
  • Imported in distributed.protocol.tests.test_highlevelgraph.
  • Imported in distributed.protocol.tests.test_netcdf4.
  • Imported in distributed.protocol.tests.test_numpy.
  • Imported in distributed.protocol.tests.test_serialize.
  • Imported in distributed.tests.test_actor.
  • Imported in distributed.tests.test_as_completed.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_collections.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.tests.test_events.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_locks.
  • Imported in distributed.tests.test_nanny.
  • Imported in distributed.tests.test_priorities.
  • Imported in distributed.tests.test_publish.
  • Imported in distributed.tests.test_pubsub.
  • Imported in distributed.tests.test_queues.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_stress.
  • Imported in distributed.tests.test_utils_comm.
  • Imported in distributed.tests.test_utils_test.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_versions.
  • Imported in distributed.tests.test_worker.
  • Imported in distributed.tests.test_worker_client.
• ▶ def gen_test(timeout=10)

  Coroutine test

  source link

  @gen_test(timeout=5)
  async def test_foo():
      await ...  # use tornado coroutines

  Reexports

  • Imported in distributed.comm.tests.test_ucx.
  • Imported in distributed.comm.tests.test_ucx_config.
  • Imported in distributed.deploy.tests.test_adaptive.
  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.protocol.tests.test_serialize.
  • Imported in distributed.tests.test_asyncprocess.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_nanny.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_utils.
  • Imported in distributed.tests.test_utils_test.
  • Imported in distributed.tests.test_worker.
• ▶ def gen_tls_cluster(**kwargs)

  source link

  Reexports

  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.tests.test_tls_functional.
• ▶ def get_cert(filename)

  Get the path to one of the test TLS certificates.

  source link

  Reexports

  • Imported in distributed.cli.tests.test_tls_cli.
  • Imported in distributed.comm.tests.test_comms.
  • Imported in distributed.dashboard.tests.test_scheduler_bokeh.
  • Imported in distributed.tests.test_security.
• ▶ def get_client_ssl_context(certfile="tls-cert.pem", keyfile="tls-key.pem", ca_file="tls-ca-cert.pem")

  source link

  Reexports

  • Imported in distributed.comm.tests.test_comms.
• ▶ def get_server_ssl_context(certfile="tls-cert.pem", keyfile="tls-key.pem", ca_file="tls-ca-cert.pem")

  source link

  Reexports

  • Imported in distributed.comm.tests.test_comms.
• ▶ def has_ipv6() @memoize

  Return whether IPv6 is locally functional. This doesn't guarantee IPv6 is properly configured outside of localhost.

  @memoize
  def has_ipv6()

  source link

  Reexports

  • Imported in distributed.comm.tests.test_comms.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.tests.test_utils.
• ▶ def inc(x)

  source link

  Reexports

  • Imported in distributed.comm.tests.test_ucx.
  • Imported in distributed.comm.tests.test_ucx_config.
  • Imported in distributed.dashboard.tests.test_scheduler_bokeh.
  • Imported in distributed.dashboard.tests.test_worker_bokeh.
  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.diagnostics.tests.test_graph_layout.
  • Imported in distributed.diagnostics.tests.test_progress.
  • Imported in distributed.diagnostics.tests.test_progress_stream.
  • Imported in distributed.diagnostics.tests.test_progressbar.
  • Imported in distributed.diagnostics.tests.test_scheduler_plugin.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.diagnostics.tests.test_worker_plugin.
  • Imported in distributed.http.scheduler.tests.test_scheduler_http.
  • Imported in distributed.protocol.tests.test_serialize.
  • Imported in distributed.tests.test_as_completed.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_nanny.
  • Imported in distributed.tests.test_priorities.
  • Imported in distributed.tests.test_publish.
  • Imported in distributed.tests.test_queues.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_stress.
  • Imported in distributed.tests.test_tls_functional.
  • Imported in distributed.tests.test_utils.
  • Imported in distributed.tests.test_utils_test.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_worker.
  • Imported in distributed.tests.test_worker_client.
• ▷ def invalid_python_script(tmpdir_factory) @pytest.fixture(scope="session")

  @pytest.fixture(scope="session")
  def invalid_python_script(tmpdir_factory)

  source link
• ▶ def loop() @pytest.fixture

  @pytest.fixture
  def loop()

  source link

  Reexports

  • Imported in distributed.cli.tests.test_dask_scheduler.
  • Imported in distributed.cli.tests.test_dask_worker.
  • Imported in distributed.cli.tests.test_tls_cli.
  • Imported in distributed.comm.tests.test_comms.
  • Imported in distributed.comm.tests.test_ucx.
  • Imported in distributed.comm.tests.test_ucx_config.
  • Imported in distributed.deploy.tests.test_adaptive.
  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.deploy.tests.test_old_ssh.
  • Imported in distributed.deploy.tests.test_spec_cluster.
  • Imported in distributed.deploy.tests.test_ssh.
  • Imported in distributed.diagnostics.tests.test_progressbar.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.tests.test_actor.
  • Imported in distributed.tests.test_as_completed.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_collections.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.tests.test_counter.
  • Imported in distributed.tests.test_events.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_ipython.
  • Imported in distributed.tests.test_locks.
  • Imported in distributed.tests.test_preload.
  • Imported in distributed.tests.test_publish.
  • Imported in distributed.tests.test_queues.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_stress.
  • Imported in distributed.tests.test_utils.
  • Imported in distributed.tests.test_utils_comm.
  • Imported in distributed.tests.test_utils_test.
  • Imported in distributed.tests.test_variable.
  • Imported in distributed.tests.test_versions.
  • Imported in distributed.tests.test_worker.
  • Imported in distributed.tests.test_worker_client.
• ▶ def loop_in_thread() @pytest.fixture

  @pytest.fixture
  def loop_in_thread()

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_utils.
• ▶ def map_varying(itemslists)

  Like *varying*, but return the full specification for a map() call on multiple items lists.

  source link

  Reexports

  • Imported in distributed.tests.test_client.
• ▶ def mock_ipython() @contextmanager

  @contextmanager
  def mock_ipython()

  source link

  Reexports

  • Imported in distributed.tests.test_ipython.
• ▶ def mul(x, y)

  source link

  Reexports

  • Imported in distributed.tests.test_worker.
• ▶ def new_config(new_config) @contextmanager

  Temporarily change configuration dictionary.

  @contextmanager
  def new_config(new_config)

  source link

  Reexports

  • Imported in distributed.tests.test_config.
  • Imported in distributed.tests.test_utils_test.
• ▶ def new_config_file(c) @contextmanager

  Temporarily change configuration file to match dictionary *c*.

  @contextmanager
  def new_config_file(c)

  source link

  Reexports

  • Imported in distributed.cli.tests.test_tls_cli.
  • Imported in distributed.tests.test_config.
• ▷ def new_environment(changes) @contextmanager

  @contextmanager
  def new_environment(changes)

  source link
• ▶ def nodebug(func)

  A decorator to disable debug facilities during timing-sensitive tests. Warning: this doesn't affect already created IOLoops.

  source link

  Reexports

  • Imported in distributed.deploy.tests.test_adaptive.
  • Imported in distributed.diagnostics.tests.test_progress.
  • Imported in distributed.tests.test_asyncprocess.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_worker.
• ▶ def nodebug_setup_module(module)

  A setup_module() that you can install in a test module to disable debug facilities.

  source link

  Reexports

  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_stress.
• ▶ def nodebug_teardown_module(module)

  A teardown_module() that you can install in a test module to reenable debug facilities.

  source link

  Reexports

  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_stress.
• ▶ def popen(args, **kwargs) @contextmanager

  @contextmanager
  def popen(args, **kwargs)

  source link

  Reexports

  • Imported in distributed.cli.tests.test_dask_scheduler.
  • Imported in distributed.cli.tests.test_dask_spec.
  • Imported in distributed.cli.tests.test_dask_worker.
  • Imported in distributed.cli.tests.test_tls_cli.
  • Imported in distributed.comm.tests.test_ucx.
  • Imported in distributed.comm.tests.test_ucx_config.
  • Imported in distributed.tests.test_client.
• ▶ def pristine_loop() @contextmanager

  @contextmanager
  def pristine_loop()

  source link

  Reexports

  • Imported in distributed.tests.test_asyncprocess.
  • Imported in distributed.tests.test_client.
• ▷ def raises(func, exc=Exception)

  source link
• ▶ def randominc(x, scale=1)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
• ▷ def reset_config()

  source link
• ▶ def run_for(duration, timer=time)

  Burn CPU for *duration* seconds.

  source link

  Reexports

  • Imported in distributed.tests.test_metrics.
  • Imported in distributed.tests.test_utils_perf.
• ▷ def run_nanny(q, scheduler_q, **kwargs)

  source link
• ▷ def run_scheduler(q, nputs, port=0, **kwargs)

  source link
• ▷ def run_worker(q, scheduler_q, **kwargs)

  source link
• ▶ def s(cluster_fixture) @pytest.fixture

  @pytest.fixture
  def s(cluster_fixture)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_worker.
• ▶ def save_sys_modules() @contextmanager

  @contextmanager
  def save_sys_modules()

  source link

  Reexports

  • Imported in distributed.tests.test_client.
• ▶ def security() @pytest.fixture

  @pytest.fixture
  def security()

  source link

  Reexports

  • Imported in distributed.tests.test_utils_test.
• ▶ def slowadd(x, y, delay=0.02)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_stress.
  • Imported in distributed.tests.test_tls_functional.
• ▶ def slowdec(x, delay=0.02)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_priorities.
  • Imported in distributed.tests.test_scheduler.
• ▷ def slowdouble(x, delay=0.02)

  source link
• ▶ def slowidentity(*args, **kwargs)

  source link

  Reexports

  • Imported in distributed.tests.test_semaphore.
  • Imported in distributed.tests.test_steal.
• ▶ def slowinc(x, delay=0.02)

  source link

  Reexports

  • Imported in distributed.dashboard.tests.test_components.
  • Imported in distributed.dashboard.tests.test_scheduler_bokeh.
  • Imported in distributed.deploy.tests.test_adaptive.
  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.deploy.tests.test_slow_adaptive.
  • Imported in distributed.diagnostics.tests.test_task_stream.
  • Imported in distributed.http.scheduler.tests.test_scheduler_http.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_failed_workers.
  • Imported in distributed.tests.test_priorities.
  • Imported in distributed.tests.test_resources.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_steal.
  • Imported in distributed.tests.test_stress.
  • Imported in distributed.tests.test_tls_functional.
  • Imported in distributed.tests.test_worker.
• ▶ def slowsum(seq, delay=0.02)

  source link

  Reexports

  • Imported in distributed.tests.test_stress.
• ▶ def terminate_process(proc)

  source link

  Reexports

  • Imported in distributed.cli.tests.test_dask_worker.
• ▶ def throws(x)

  source link

  Reexports

  • Imported in distributed.diagnostics.tests.test_widgets.
  • Imported in distributed.tests.test_as_completed.
  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.tests.test_utils.
• ▶ def tls_client(tls_cluster, loop, security) @pytest.fixture

  @pytest.fixture
  def tls_client(

  tls_cluster,

  loop,

  security,

  )

  source link

  Reexports

  • Imported in distributed.tests.test_utils_test.
• ▶ def tls_cluster(loop, security) @pytest.fixture

  @pytest.fixture
  def tls_cluster(

  loop,

  security,

  )

  source link

  Reexports

  • Imported in distributed.tests.test_utils_test.
• ▷ def tls_cluster_context(worker_kwargs=None, scheduler_kwargs=None, security=None, **kwargs) @contextmanager

  @contextmanager
  def tls_cluster_context(

  worker_kwargs=None,

  scheduler_kwargs=None,

  security=None,

  **kwargs,

  )

  source link
• ▶ def tls_config()

  A functional TLS configuration with our test certs.

  source link

  Reexports

  • Imported in distributed.tests.test_tls_functional.
• ▶ def tls_only_config()

  A functional TLS configuration with our test certs, disallowing plain TCP communications.

  source link

  Reexports

  • Imported in distributed.cli.tests.test_tls_cli.
• ▶ def tls_only_security()

  A Security object with proper TLS configuration and disallowing plain TCP communications.

  source link

  Reexports

  • Imported in distributed.deploy.tests.test_local.
  • Imported in distributed.tests.test_scheduler.
  • Imported in distributed.tests.test_utils_test.
• ▶ def tls_security()

  A Security object with proper TLS configuration.

  source link

  Reexports

  • Imported in distributed.cli.tests.test_tls_cli.
  • Imported in distributed.tests.test_core.
• ▷ def valid_python_script(tmpdir_factory) @pytest.fixture(scope="session")

  @pytest.fixture(scope="session")
  def valid_python_script(tmpdir_factory)

  source link
• ▶ def varying(items)

  Return a function that returns a result (or raises an exception) from *items* at each call.

  source link

  Reexports

  • Imported in distributed.tests.test_client.
  • Imported in distributed.tests.test_client_executor.
  • Imported in distributed.tests.test_scheduler.
• ▶ def wait_for(predicate, timeout, fail_func=None, period=0.001)

  source link

  Reexports

  • Imported in distributed.tests.test_client.
• ▶ def wait_for_port(address, timeout=5)

  source link

  Reexports

  • Imported in distributed.cli.tests.test_dask_worker.
  • Imported in distributed.tests.test_utils_test.
• ▶ def zmq_ctx() @pytest.fixture

  @pytest.fixture
  def zmq_ctx()

  source link

  Reexports

  • Imported in distributed.tests.test_ipython.

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