task

type ExecutionInfo struct {
	TaskID     uuid.UUID
	Components []WorkflowComponent

	// RuleDefinition is the resolved operation rule, determined at task
	// creation time and carried through to the workflow unchanged.
	RuleDefinition *operationrules.RuleDefinition

	// OperationType identifies which workflow to dispatch to. The executor
	// looks up the registered WorkflowDescriptor by this value and submits
	// the workflow by its stable Temporal name.
	OperationType taskcommon.TaskType

	// OperationInfo is the serialized operation-specific payload. The
	// executor passes it to the WorkflowDescriptor's Unmarshal function,
	// which deserializes and validates it before the workflow starts.
	OperationInfo json.RawMessage
}

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"`
}