Function waitForTask

internal/cli/cli_helpers.go:603–627

waitForTask polls a Proxmox task to completion using the existing WaitForTaskCompletion method and returns the final exit status string. It respects ctx cancellation (e.g. Ctrl-C).

(ctx context.Context, client *api.Client, node, upid, operationName string)

// WaitForTaskCompletion method and returns the final exit status string.
// It respects ctx cancellation (e.g. Ctrl-C).
func waitForTask(ctx context.Context, client *api.Client, node, upid, operationName string) (exitStatus string, err error) {
	const defaultTimeout = 10 * time.Minute

	done := make(chan error, 1)
	go func() {
		done <- client.WaitForTaskCompletion(upid, operationName, defaultTimeout)
	}()

	select {
	case <-ctx.Done():
		return "", fmt.Errorf("%s cancelled", operationName)
	case err = <-done:
		if err != nil {
			return "ERROR", err
		}
	}

	// Fetch final status for structured output.
	status, fetchErr := client.GetTaskStatus(node, upid)
	if fetchErr != nil || status == nil {
		return "OK", nil
	}

	return status.ExitStatus, nil
}

// inferGuestTypeFromVolID returns "qemu" or "lxc" based on the vzdump volid prefix.
func inferGuestTypeFromVolID(volID string) (string, error) {