task

type ExecutionInfo struct {
	TaskID         uuid.UUID
	Components     []WorkflowComponent
	RuleDefinition *operationrules.RuleDefinition
}

type ExecutionRequest struct {
	Info  ExecutionInfo
	Async bool
}

type ExecutionResponse struct {
	ExecutionID string
}

type Task struct {
	ID            uuid.UUID
	Operation     operation.Wrapper
	RackID        uuid.UUID // The rack this task operates on (1 task = 1 rack)
	Attributes    taskcommon.TaskAttributes
	Description   string
	ExecutorType  taskcommon.ExecutorType
	ExecutionID   string
	Status        taskcommon.TaskStatus
	Message       string
	AppliedRuleID *uuid.UUID // The ID of the operation rule that was applied
	CreatedAt     time.Time
	UpdatedAt     time.Time
	StartedAt     *time.Time
	FinishedAt    *time.Time

	// QueueExpiresAt is the deadline for a waiting task to be promoted.
	// After this time the Promoter terminates the task automatically.
	// Nil for non-waiting tasks.
	QueueExpiresAt *time.Time
}

type TaskStatusUpdate struct {
	ID      uuid.UUID
	Status  taskcommon.TaskStatus
	Message string
}

type TaskStatusUpdater interface {
	// UpdateTaskStatus persists the status change described by arg.
	UpdateTaskStatus(ctx context.Context, arg *TaskStatusUpdate) error
}

type WorkflowComponent struct {
	Type        devicetypes.ComponentType `json:"type"`
	ComponentID string                    `json:"component_id"`
}