Module core

Classes

• class ConnectionPool
  A maximum sized pool of Comm objects.
• class PooledRPCCall
  The result of ConnectionPool()('host:port')
• class RPCClosed
• class Server
  Dask Distributed Server
• class Status
  This Enum contains the various states a worker, scheduler and nanny can be
• class rpc
  Conveniently interact with a remote server

Functions

• ▷ def addr_from_args(addr=None, ip=None, port=None)

  source link
• ▶ def clean_exception(exception, traceback, **kwargs)

  Reraise exception and traceback. Deserialize if necessary

  source link

  See also

  error_message: create and serialize errors into message

  Reexports

  • Imported in distributed.client.
  • Imported in distributed.scheduler.
• ▶ def coerce_to_address(o)

  source link

  Reexports

  • Imported in distributed.diagnostics.eventstream.
  • Imported in distributed.diagnostics.progress_stream.
  • Imported in distributed.diagnostics.progressbar.
  • Imported in distributed.nanny.
  • Imported in distributed.tests.test_core.
  • Imported in distributed.worker.
• ▷ def collect_causes(e)

  source link
• ▶ def error_message(e, status="error")

  Produce message to send back given an exception has occurred

  source link

  This does the following:
  
  1.  Gets the traceback
  2.  Truncates the exception and the traceback
  3.  Serializes the exception and traceback or
  4.  If they can't be serialized send string versions
  5.  Format a message and return

  See also

  clean_exception: deserialize and unpack message into exception/traceback

  Reexports

  • Imported in distributed.tests.test_worker.
  • Imported in distributed.worker.
• ▶ def pingpong(comm)

  source link

  Reexports

  • Imported in distributed.tests.test_core.
  • Imported in distributed.worker.
• ▷ def raise_later(exc)

  source link

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