Class ReplayExceptionScheduler

distributed.recreate_exceptions.ReplayExceptionScheduler

A plugin for the scheduler to recreate exceptions locally

Declaration

class ReplayExceptionScheduler

Documentation

This adds the following routes to the scheduler

*  cause_of_failure

Methods

▷ def __init__(self, scheduler)
source link
▶ def cause_of_failure(self, *args, keys=(), **kwargs)
Return details of first failed task required by set of keys
source link
Parameters
- keys : list of keys known to the scheduler
Returns

Reexports

Imported in distributed.scheduler.