run

type ActiveRunsInput struct {
	TurnId         string
	ConversationId string
	Has            *ActiveRunsInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

type ActiveRunsInputHas struct {
	TurnId         bool
	ConversationId bool
}

type ActiveRunsOutput struct {
	response.Status `json:",omitempty"`
	Data            []*ActiveRunsView
	Metrics         response.Metrics
}

type ActiveRunsView = read.RunRowsView

type MutableRunView struct {
	Id                    string     `sqlx:"id,primaryKey" validate:"required"`
	TurnID                *string    `sqlx:"turn_id" json:",omitempty"`
	ScheduleID            *string    `sqlx:"schedule_id" json:",omitempty"`
	ConversationID        *string    `sqlx:"conversation_id" json:",omitempty"`
	ConversationKind      *string    `sqlx:"conversation_kind" json:",omitempty"`
	Attempt               *int       `sqlx:"attempt" json:",omitempty"`
	ResumedFromRunID      *string    `sqlx:"resumed_from_run_id" json:",omitempty"`
	Status                string     `sqlx:"status" validate:"required"`
	ErrorCode             *string    `sqlx:"error_code" json:",omitempty"`
	ErrorMessage          *string    `sqlx:"error_message" json:",omitempty"`
	Iteration             *int       `sqlx:"iteration" json:",omitempty"`
	MaxIterations         *int       `sqlx:"max_iterations" json:",omitempty"`
	CheckpointResponseID  *string    `sqlx:"checkpoint_response_id" json:",omitempty"`
	CheckpointMessageID   *string    `sqlx:"checkpoint_message_id" json:",omitempty"`
	CheckpointData        *string    `sqlx:"checkpoint_data" json:",omitempty"`
	AgentID               *string    `sqlx:"agent_id" json:",omitempty"`
	ModelProvider         *string    `sqlx:"model_provider" json:",omitempty"`
	Model                 *string    `sqlx:"model" json:",omitempty"`
	WorkerID              *string    `sqlx:"worker_id" json:",omitempty"`
	WorkerPID             *int       `sqlx:"worker_pid" json:",omitempty"`
	WorkerHost            *string    `sqlx:"worker_host" json:",omitempty"`
	LeaseOwner            *string    `sqlx:"lease_owner" json:",omitempty"`
	LeaseUntil            *time.Time `sqlx:"lease_until" json:",omitempty"`
	LastHeartbeatAt       *time.Time `sqlx:"last_heartbeat_at" json:",omitempty"`
	SecurityContext       *string    `sqlx:"security_context" json:",omitempty"`
	UserCredURL           *string    `sqlx:"user_cred_url" json:",omitempty"`
	EffectiveUserID       *string    `sqlx:"effective_user_id" json:",omitempty"`
	AuthAuthority         *string    `sqlx:"auth_authority" json:",omitempty"`
	AuthAudience          *string    `sqlx:"auth_audience" json:",omitempty"`
	HeartbeatIntervalSec  *int       `sqlx:"heartbeat_interval_sec" json:",omitempty"`
	ScheduledFor          *time.Time `sqlx:"scheduled_for" json:",omitempty"`
	PreconditionRanAt     *time.Time `sqlx:"precondition_ran_at" json:",omitempty"`
	PreconditionPassed    *int       `sqlx:"precondition_passed" json:",omitempty"`
	PreconditionResult    *string    `sqlx:"precondition_result" json:",omitempty"`
	UsagePromptTokens     *int       `sqlx:"usage_prompt_tokens" json:",omitempty"`
	UsageCompletionTokens *int       `sqlx:"usage_completion_tokens" json:",omitempty"`
	UsageTotalTokens      *int       `sqlx:"usage_total_tokens" json:",omitempty"`
	UsageCost             *float64   `sqlx:"usage_cost" json:",omitempty"`
	CreatedAt             *time.Time `sqlx:"created_at" json:",omitempty"`
	UpdatedAt             *time.Time `sqlx:"updated_at" json:",omitempty"`
	StartedAt             *time.Time `sqlx:"started_at" json:",omitempty"`
	CompletedAt           *time.Time `sqlx:"completed_at" json:",omitempty"`
	Has                   *RunHas    `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
	// Condition, when set, turns this sparse update into an atomic
	// compare-and-set (see RunPatchCondition). It is not a column.
	Condition *RunPatchCondition `sqlx:"-" diff:"-" json:",omitempty"`
}

type MutableRunViewOption func(*MutableRunView)

type MutableRunViews struct {
	Runs []*MutableRunView
}

type RunHas struct {
	Id                    bool
	TurnID                bool
	ScheduleID            bool
	ConversationID        bool
	ConversationKind      bool
	Attempt               bool
	ResumedFromRunID      bool
	Status                bool
	ErrorCode             bool
	ErrorMessage          bool
	Iteration             bool
	MaxIterations         bool
	CheckpointResponseID  bool
	CheckpointMessageID   bool
	CheckpointData        bool
	AgentID               bool
	ModelProvider         bool
	Model                 bool
	WorkerID              bool
	WorkerPID             bool
	WorkerHost            bool
	LeaseOwner            bool
	LeaseUntil            bool
	LastHeartbeatAt       bool
	HeartbeatIntervalSec  bool
	SecurityContext       bool
	UserCredURL           bool
	EffectiveUserID       bool
	ScheduledFor          bool
	PreconditionRanAt     bool
	PreconditionPassed    bool
	PreconditionResult    bool
	UsagePromptTokens     bool
	UsageCompletionTokens bool
	UsageTotalTokens      bool
	UsageCost             bool
	CreatedAt             bool
	UpdatedAt             bool
	StartedAt             bool
	CompletedAt           bool
}

type RunPatchCondition struct {
	// Status is the expected current run status (required for claim shapes).
	Status string `json:",omitempty"`
	// LeaseOwner is the expected current lease owner. nil means "no owner
	// criterion" (legacy rows with NULL lease_owner); it must be combined
	// with Status and Attempt.
	LeaseOwner *string `json:",omitempty"`
	// Attempt is the expected current attempt.
	Attempt *int `json:",omitempty"`
}

type RunRowsInput struct {
	Id               string
	TurnId           string
	ConversationId   string
	ScheduleId       string
	WorkerId         string
	RunStatus        string
	ExcludeStatuses  []string
	DefaultPredicate string
	Has              *RunRowsInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

type RunRowsInputHas struct {
	Id               bool
	TurnId           bool
	ConversationId   bool
	ScheduleId       bool
	WorkerId         bool
	RunStatus        bool
	ExcludeStatuses  bool
	DefaultPredicate bool
}

type RunRowsOutput struct {
	response.Status `json:",omitempty"`
	Data            []*RunRowsView
	Metrics         response.Metrics
}

type RunRowsView = read.RunRowsView

type RunStepsInput struct {
	RunID        string
	Iteration    int
	StepTypes    []string
	CursorBefore string
	CursorAfter  string
	Has          *RunStepsInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

type RunStepsInputHas struct {
	RunID        bool
	Iteration    bool
	StepTypes    bool
	CursorBefore bool
	CursorAfter  bool
}

type RunStepsOutput struct {
	response.Status `json:",omitempty"`
	Data            []*RunStepsView
	Metrics         response.Metrics
}

type RunStepsView = read.RunStepsView

type StaleRunsInput struct {
	HeartbeatBefore    time.Time
	WorkerHost         string
	LeaseExpiredBefore time.Time
	ActivityAfter      time.Time
	ConversationKind   string
	RootInteractive    bool
	Has                *StaleRunsInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

type StaleRunsInputHas struct {
	HeartbeatBefore    bool
	WorkerHost         bool
	LeaseExpiredBefore bool
	ActivityAfter      bool
	ConversationKind   bool
	RootInteractive    bool
}

type StaleRunsOutput struct {
	response.Status `json:",omitempty"`
	Data            []*StaleRunsView
	Metrics         response.Metrics
}

type StaleRunsView = read.RunRowsView