nodebuild

type MaterializeRequest struct {
	// Analysis is the owning analysis row; its output directory anchors the
	// workspace and its project id is copied onto the node.
	Analysis *types.Analysis
	// Spec is the compiled process template.
	Spec *Spec
	// Status is the initial node status.
	Status string
	// ErrorMessage explains a non-ready initial status (for example skipped).
	ErrorMessage string
	// CreationSource overrides the default creation_source marker.
	CreationSource string
	// Incoming are the edges that target this node, used to bootstrap inputs.
	Incoming []*types.AnalysisEdge
	// Upstream maps node id -> persisted node, used to resolve edge sources.
	Upstream map[string]*types.AnalysisNode
	// Ctx carries the request context for the optional select-assay input parser.
	Ctx context.Context
	// Parser optionally produces the structured recipe for inputs whose declared
	// type needs the original request form (currently SelectAssay). nil skips it.
	Parser dagruntime.NodeRequestParser
	// WorkspaceDir overrides the derived workspace root when a caller has
	// already allocated one.
	WorkspaceDir string
	// NodeRecordID overrides the generated primary key (tests only).
	NodeRecordID int64
}

type ProbeRequest struct {
	// Analysis is the owning analysis row.
	Analysis *types.Analysis
	// Spec is the freshly compiled template to compare against.
	Spec *Spec
	// Existing is the node persisted by a previous run.
	Existing *types.AnalysisNode
	// Incoming are the edges that target this node.
	Incoming []*types.AnalysisEdge
	// Upstream maps node id -> persisted node.
	Upstream map[string]*types.AnalysisNode
	// Ctx carries the request context for the optional select-assay input parser.
	Ctx context.Context
	// Parser optionally produces the structured recipe for inputs whose declared
	// type needs the original request form (currently SelectAssay). nil skips it.
	Parser dagruntime.NodeRequestParser
}

type Spec struct {
	// AnalysisNodeID is the compiler-assigned, rerun-stable identity. Empty means
	// "generate one".
	AnalysisNodeID string
	// NodeID is the runtime identity used by edges.
	NodeID string
	// NodeName is the human readable instance name.
	NodeName string
	// SampleID identifies the scattered sample, empty for singletons.
	SampleID string
	// ScriptID is the resolved pipeline_components primary key.
	ScriptID int64
	// Executor selects the runtime backend (container, local, ...).
	Executor string
	// InputsPatterns declares input handles and their schemas.
	InputsPatterns types.JSONMap
	// ResolvedInputs holds the resolved input payload.
	ResolvedInputs types.JSONMap
	// OutputPatterns declares output handles and their schemas.
	OutputPatterns types.JSONMap
	// ResolvedOutputs holds the predicted outputs.
	ResolvedOutputs types.JSONMap
	// RequestParam is the original analysis request_param carried onto the node so
	// a single node can be re-run or edited with the same request context.
	RequestParam types.JSONMap
	// UpstreamIDs lists declared upstream node identities.
	UpstreamIDs []string
	// DownstreamIDs lists declared downstream node identities.
	DownstreamIDs []string
	// InputValidationErrors lists compile-time input problems.
	InputValidationErrors types.JSONSlice
	// Retry / MaxRetry configure in-place retries.
	Retry    int
	MaxRetry int
	// RerunReason carries a compiler supplied rerun explanation.
	RerunReason string
	// InputHash overrides the computed instance identity; empty computes it.
	InputHash string
}

type WorkspaceLayout struct {
	// Dir is the node root directory.
	Dir string
	// OutputDir receives produced artifacts.
	OutputDir string
	// CacheDir holds intermediate cache artifacts.
	CacheDir string
	// ParamsPath is the generated params.json path.
	ParamsPath string
	// CommandPath is the generated run.sh path.
	CommandPath string
	// LogPath is the captured command log path.
	LogPath string
}