Method completeTask

internal/taskmanager/manager.go:208–234

(task *Task, status TaskStatus, err error)

}

func (tm *TaskManager) completeTask(task *Task, status TaskStatus, err error) {
	tm.mu.Lock()
	task.Status = status
	task.Error = err
	task.FinishedAt = time.Now()

	key := taskKey(task.TargetNode, task.TargetVMID)

	// Remove from active
	delete(tm.activeTasks, key)

	// Check queue for next task, respecting max running task cap.
	nextTask := tm.dequeueNextStartableLocked(key)
	tm.mu.Unlock()

	if task.OnComplete != nil {
		go task.OnComplete(err)
	}

	if tm.updateNotify != nil {
		go tm.updateNotify()
	}

	if nextTask != nil {
		go tm.runTask(nextTask)
	}
}

func (tm *TaskManager) dequeueNextStartableLocked(preferredKey string) *Task {
	if len(tm.activeTasks) >= tm.maxRunning {