Class Processing

distributed.dashboard.components.shared.Processing

Processing and distribution per core

Declaration

class Processing(DashboardComponent)

Documentation

This shows how many tasks are actively running on each worker and how many
tasks are enqueued for each worker and how many are in the common pool

Methods

▶ def __init__(self, **kwargs) override
source link
This method overrides distributed.dashboard.components.DashboardComponent.__init__.
▶ def update(self, messages) override @without_property_validation
inherited doc Reads from bokeh.distributed.messages and updates self.source
@without_property_validation
def update(
self,
messages,
)
source link
This method overrides distributed.dashboard.components.DashboardComponent.update.

Class methods

▷ def processing_update(msg) @staticmethod
@staticmethod
def processing_update(msg)
source link

Reexports

Imported in distributed.dashboard.tests.test_components.