Method WaitForTaskCompletion

pkg/api/vm_snapshots.go:157–200

WaitForTaskCompletion polls for task completion and returns an error if the task failed. This is a public wrapper that allows specifying a custom timeout. Proxmox task completion is determined by checking the EndTime field: - If EndTime > 0, the task has finished - If Status == "OK", the task succe

(upid string, operationName string, maxWait time.Duration)

//
// Returns an error if the task fails or times out.
func (c *Client) WaitForTaskCompletion(upid string, operationName string, maxWait time.Duration) error {
	c.logger.Debug("Waiting for task completion: %s (timeout: %v)", upid, maxWait)

	pollInterval := 2 * time.Second
	start := time.Now()

	for time.Since(start) < maxWait {
		tasks, err := c.GetClusterTasks()
		if err != nil {
			c.logger.Debug("Failed to get cluster tasks: %v", err)
			time.Sleep(pollInterval)
			continue
		}

		// Find our task
		for _, task := range tasks {
			if task.UPID == upid {
				c.logger.Debug("Found task %s, status: %q, endtime: %d", upid, task.Status, task.EndTime)

				// Task is complete when EndTime > 0
				if task.EndTime > 0 {
					// Check if task succeeded
					if task.Status == "OK" {
						c.logger.Debug("Task %s completed successfully", upid)
						return nil
					}
					// Task completed but failed - Status contains error message
					errorMsg := task.Status
					if errorMsg == "" {
						errorMsg = "unknown error (empty status)"
					}
					c.logger.Debug("Task %s failed with status: %s", upid, errorMsg)
					return fmt.Errorf("%s failed: %s", operationName, errorMsg)
				}
				// Task is still running (EndTime == 0), continue polling
				break
			}
		}

		time.Sleep(pollInterval)
	}

	return fmt.Errorf("%s timed out after %v waiting for task %s", operationName, maxWait, upid)
}

// waitForTaskCompletion is a private wrapper for backward compatibility with snapshots.
func (c *Client) waitForTaskCompletion(upid string, operationName string) error {