func (d *Dispatcher) isRunningLocked() (context.Context, error) {
    d.mu.Lock()
    if !d.isRunning() {
        d.mu.Unlock()
        return nil, status.Errorf(codes.Aborted, "dispatcher is stopped")