Module scheduler

Classes

• class AggregateAction
  Bar chart showing time spend in action by key prefix
• class BandwidthTypes
  Bar chart showing bandwidth per type
• class BandwidthWorkers
  How many tasks are on each worker
• class ComputePerKey
  Bar chart showing time spend in action by key prefix
• class CurrentLoad
  How many tasks are on each worker
• class Events
• class MemoryByKey
  Bar chart showing memory use by key prefix
• class NBytesHistogram
  How many tasks are on each worker
• class Occupancy
  Occupancy (in time) per worker
• class ProcessingHistogram
  How many tasks are on each worker
• class StealingEvents
• class StealingTimeSeries
• class TaskGraph
  A dynamic node-link diagram for the task graph on the scheduler
• class TaskProgress
  Progress bars per task type
• class TaskStream
• class WorkerTable
  Status of the current workers

Functions

• ▶ def events_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def graph_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_aggregate_time_per_action_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_bandwidth_types_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_bandwidth_workers_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_compute_time_per_key_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_cpu_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_graph_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_memory_by_key_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_nbytes_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_nprocessing_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_profile_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_profile_server_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_progress_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_task_stream_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def individual_workers_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def profile_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def profile_server_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def status_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def stealing_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def systemmonitor_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▷ def task_stream_figure(clear_interval="20s", **kwargs)

  kwargs are applied to the bokeh.models.plots.Plot constructor

  source link
• ▶ def tasks_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.
• ▶ def workers_doc(scheduler, extra, doc)

  source link

  Reexports

  • Imported in distributed.dashboard.scheduler.

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