executions

type API struct {

	// Observer receives per-node progress for synchronous runs — the
	// CLI sets it; servers leave it nil.
	Observer workflowruntime.RunObserver
	// contains filtered or unexported fields
}

type CreateRequest struct {
	WorkflowSlug string         `json:"workflow_slug,omitempty"`
	File         string         `json:"file,omitempty"`
	Input        map[string]any `json:"input"`
	ProjectDir   string         `json:"project_dir,omitempty"`
	// Worktree is a branch name; the run executes in that branch's
	// worktree of the ProjectDir repository (created on demand).
	Worktree string `json:"worktree,omitempty"`
	// Base is the start point when Worktree creates a new branch.
	Base string `json:"base,omitempty"`
	// ResumeFromExecutionID + ResumeFromNode re-run a prior execution
	// from one node: upstream outputs are reused by reference, the node
	// and everything downstream of it run again.
	ResumeFromExecutionID string `json:"resume_from_execution_id,omitempty"`
	ResumeFromNode        string `json:"resume_from_node,omitempty"`
	// UseCurrentSpec recompiles the workflow's current YAML instead of
	// replaying the stored snapshot (e.g. after a prompt edit).
	UseCurrentSpec bool `json:"use_current_spec,omitempty"`
}

type CreateResponse struct {
	ExecutionID     string                                  `json:"execution_id,omitempty"`
	WorkflowSlug    string                                  `json:"workflow_slug"`
	WorkflowVersion string                                  `json:"workflow_version"`
	Status          executionmodels.WorkflowExecutionStatus `json:"status"`
}

type ExecutionFailedError struct {
	Details ExecutionFailureDetails
	Err     error
}

type ExecutionFailureDetails struct {
	ExecutionID     string
	WorkflowSlug    string
	WorkflowVersion string
	NodeExecutionID string
	NodeID          string
	NodeError       string
	ConversationID  string
	HarnessExitCode int
	HarnessError    string
}

type GetRequest struct {
	WorkflowExecutionID uuid.UUID `json:"workflow_execution_id"`
}

type ListRequest struct {
	pagination.CursorRequest

	WorkflowSlug string `json:"workflow_slug,omitempty"`
}

type ListResponse struct {
	pagination.CursorResponse
	WorkflowExecutions []execution.WorkflowExecution `json:"workflow_executions"`
}

type RunResponse struct {
	ExecutionID     string                                  `json:"execution_id,omitempty"`
	WorkflowSlug    string                                  `json:"workflow_slug"`
	WorkflowVersion string                                  `json:"workflow_version"`
	Status          executionmodels.WorkflowExecutionStatus `json:"status"`
	Output          map[string]any                          `json:"output,omitempty"`
}

type StatusResponse struct {
	ExecutionID     string                                  `json:"execution_id"`
	WorkflowSlug    string                                  `json:"workflow_slug"`
	WorkflowVersion string                                  `json:"workflow_version"`
	Status          executionmodels.WorkflowExecutionStatus `json:"status"`
	StartedAt       *time.Time                              `json:"started_at,omitempty"`
	FinishedAt      *time.Time                              `json:"finished_at,omitempty"`
	Output          map[string]any                          `json:"output,omitempty"`
	Failure         *WorkflowFailureDetails                 `json:"failure,omitempty"`
}

type WorkflowFailureDetails struct {
	NodeExecutionID string `json:"node_execution_id,omitempty"`
	NodeID          string `json:"node_id,omitempty"`
	NodeError       string `json:"node_error,omitempty"`
	ConversationID  string `json:"conversation_id,omitempty"`
	HarnessExitCode int    `json:"harness_exit_code,omitempty"`
	HarnessError    string `json:"harness_error,omitempty"`
}