Method GetTaskStatus

pkg/api/cluster.go:524–565

GetTaskStatus retrieves the status of a specific task.

(node, upid string)

// GetTaskStatus retrieves the status of a specific task.
func (c *Client) GetTaskStatus(node, upid string) (*TaskStatus, error) {
	// Escape the UPID as it contains special characters
	path := fmt.Sprintf("/nodes/%s/tasks/%s/status", node, url.PathEscape(upid))

	var result map[string]interface{}
	if err := c.Get(path, &result); err != nil {
		return nil, fmt.Errorf("failed to get task status: %w", err)
	}

	data, ok := result["data"].(map[string]interface{})
	if !ok {
		return nil, fmt.Errorf("unexpected format for task status data")
	}

	task := &TaskStatus{
		Status:     getString(data, "status"),
		ExitStatus: getString(data, "exitstatus"),
		Node:       node,
		UPID:       upid,
		Type:       getString(data, "type"),
		User:       getString(data, "user"),
		ID:         getString(data, "id"),
	}

	if startTime, ok := data["starttime"].(float64); ok {
		task.StartTime = int64(startTime)
	}

	if endTime, ok := data["endtime"].(float64); ok {
		task.EndTime = int64(endTime)
	}

	if pstart, ok := data["pstart"].(float64); ok {
		task.PStart = int64(pstart)
	}

	if pid, ok := data["pid"].(float64); ok {
		task.PID = int(pid)
	}

	return task, nil
}

// StopTask attempts to stop/cancel a running task.
func (c *Client) StopTask(node, upid string) error {