return err
}
// We took over the task queue and are not sure what tasks may have been written
// before. Set max read level id of all subqueues to just before our new block.
maxReadLevel := rangeIDToTaskIDBlock(db.rangeID, db.config.RangeSize).start - 1
for _, s := range db.subqueues {
s.maxReadLevel = maxReadLevel
}
return nil
case *serviceerror.NotFound: