func (s *State) MustSetSuccess(taskName string) {
    s.mu.Lock()
    defer s.mu.Unlock()
    if s.States[taskName] != Running {
        panic(fmt.Errorf("Current state must be Running, not %s", s.States[taskName].String()))