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