Class TaskGraph

A dynamic node-link diagram for the task graph on the scheduler

Declaration

See also the GraphLayout diagnostic at
distributed/diagnostics/graph_layout.py

▷ def __del__(self)
source link
▶ def __init__(self, scheduler, **kwargs) override
source link
This method overrides distributed.dashboard.components.DashboardComponent.__init__.
▷ def add_new_nodes_edges(self, new, new_edges, update=False) @without_property_validation
@without_property_validation
def add_new_nodes_edges(
self,
new,
new_edges,
update=False,
)
source link
▷ def patch_updates(self) @without_property_validation
Small updates like color changes or lost nodes from task transitions
@without_property_validation
def patch_updates(self)
source link
▶ def update(self) override @without_property_validation
inherited doc Reads from bokeh.distributed.messages and updates self.source
@without_property_validation
def update(self)
source link
This method overrides distributed.dashboard.components.DashboardComponent.update.