Module runtime 

Runtime execution: schedulers, controllers, stores, OOF/merge logic.

Split from the former monolithic runtime.rs into cohesive submodules (pure refactor — code moved verbatim). mod.rs owns the run context, the controller registry, the custom-aggregation dispatch entry points, native variant selection, and re-exports the full runtime surface so pub use runtime::* in lib.rs resolves identically.

Structs

ArtifactHandleRecord

ArtifactInputSpec

ArtifactMaterializationRequest

ArtifactPayloadMaterializationRecord

ArtifactRef

BundleReplayExecution

ColumnarPredictionCacheBlock

ColumnarPredictionCacheManifest

ColumnarPredictionCacheStore

DataMaterializationRequest

DataOutputProvenance

DataProviderViewSpec

DataViewRequest

EnvelopeAttestedRuntimeDataProvider

Owns a host data provider while supplying envelope-backed identities at the runtime trust boundary. A complete training identity is available only when the envelope carries feature, target and relation fingerprints.

ExplanationBlock

An EXPLAIN-phase output block (ADR-12 explain contract). Explanations are a node output returned in the NodeResult — like predictions, they cross as data, not as an opaque host handle. The payload shape is controller-defined (e.g. per-feature importances); the core does not interpret it. Explanations are only valid in the EXPLAIN phase.

FileArtifactManifest

Versioned, file-backed artifact manifest. This is a manifest/portability layer only: it records portable ArtifactRef metadata for a bundle’s refit artifacts. It does not deserialize ML objects or materialize artifact payloads; payload stores remain future work.

FileArtifactManifestEntry

One persisted artifact entry. Mirrors the bundle RefitArtifactRecord identity (node, controller, artifact, parameters and training loss) while requiring the ArtifactRef to be portable so the manifest stays movable with its payloads.

FileArtifactManifestStore

File-backed artifact manifest store rooted at a directory.

FileArtifactPayloadStore

FilePredictionCacheEntry

FilePredictionCacheManifest

FilePredictionCacheStore

FitInfluenceDiagnostic

FitInfluenceTask

HandleRef

InMemoryAggregatedPredictionStore

InMemoryArtifactStore

InMemoryLineageRecorder

InMemoryPredictionCacheStore

InMemoryPredictionStore

LineageRecord

MethodsPlsData

Provider response for one PLS fit/predict invocation.

MethodsPlsDataRequest

Scheduler-owned view selection for a portable Methods PLS operation.

MethodsPlsDataset

One identity-keyed dataset returned by the portable PLS provider capability.

MethodsPlsMatrix

Row-major f64 matrix passed from an explicitly capable provider to the portable Methods PLS controller. It never crosses the public ABI.

MethodsPlsPredictDataProvider

Native, in-memory data provider for target-free Methods PLS PREDICT.

MethodsPlsPredictInput

NodeResult

NodeTask

ParallelScheduler

PredictionCacheMaterializationRecord

PredictionCacheMaterializationRequest

PredictionInputSpec

RunContext

RuntimeControllerRegistry

RuntimeHpoCampaignResult

RuntimeHpoCampaignTask

Typed scheduler operation used to create one invocation-local HPO session. It deliberately contains no graph NodePlan: the session controls variant campaigns for target_node_id, while all predictor work remains in the ordinary graph execution plan.

RuntimeHpoCandidateEvaluation

Scheduler-owned evidence retained for a successfully completed trial. Candidate OOF data remains report-only and is never reused as a training input; final SELECT/REFIT is intentionally outside this campaign call.

RuntimeHpoCheckpointResult

Durable native optimizer state paired with exact coordinator evidence. No native Context or Optimizer object crosses this boundary.

RuntimeHpoCompletedReport

The one cross-fold OOF report which terminalized a completed native trial. Keeping the native trial id beside report-grade scheduler evidence makes a checkpoint resumable without asking libn4m to invent coordinator scores.

RuntimeHpoExecutionContext

Immutable coordinator evidence for one execution-local HPO campaign.

RuntimeHpoFailure

RuntimeHpoIncumbent

One typed native incumbent, derived from the optimizer’s best() only after every scheduler-observed proposal has reached a terminal state.

RuntimeHpoIntermediate

RuntimeHpoProposal

One candidate proposed by a local tuner session. It contains a normal plan variant only; no native optimizer/context can cross the scheduler boundary.

RuntimeHpoProvenance

RuntimeHpoSelectionTarget

RuntimeHpoTerminalSnapshot

A controller-attested terminal native trial. The native record is never reconstructed from checkpoint bytes by DAG-ML; it is obtained only from the invocation-local session which owns that checkpoint.

SequentialScheduler

VariantExecutionSpec

VariantSelection

Outcome of native variant selection: the winning variant plus EVERY scored variant’s cross-validation reports, each tagged with its own variant_id.

VariantSelectionOutcome

Extended result of native variant selection.

VariantValidationPredictions

One scored variant’s VALIDATION (OOF) predictions, captured from its transient FIT_CV RunContext and re-tagged with the variant’s id + content fingerprint so a host can fill that variant’s per-sample prediction rows. REPORT-grade output paired with VariantSelection::validation_reports: it never feeds a training/feature path (see the field docs on VariantSelection::variant_validation_predictions).

Enums

ArtifactBackend

FitInfluenceMechanism

HandleKind

RuntimeHpoIntermediateOutcome

RuntimeHpoTerminal

Constants

DATA_OUTPUT_PROVENANCE_KEY

DATA_OUTPUT_PROVENANCE_SCHEMA_ID

DATA_OUTPUT_PROVENANCE_SCHEMA_VERSION

FILE_ARTIFACT_MANIFEST_FILE

FILE_ARTIFACT_MANIFEST_SCHEMA_VERSION

FILE_PREDICTION_CACHE_MANIFEST_FILE

FILE_PREDICTION_CACHE_STORE_SCHEMA_VERSION

METHODS_PLS_PREDICT_CONTENT_PROFILE

One host-materialized X-only cohort offered to the native Methods PLS controller for a fresh PREDICT replay.

NODE_RESULT_SCHEMA_ID

NODE_RESULT_SCHEMA_VERSION

NODE_TASK_SCHEMA_ID

NODE_TASK_SCHEMA_VERSION

Traits

RuntimeArtifactStore

RuntimeController

RuntimeDataProvider

RuntimePredictionCacheStore

RuntimeTunerSession

Per-campaign tuner state. Deliberately no Send or Sync supertrait: libn4m’s Context and Optimizer are thread-affine. The session proposes a portable variant; the scheduler evaluates its FIT_CV/OOF evidence and feeds the scalar intermediate/terminal state back here. This avoids a controller-owned CV loop and prevents native state from entering a Send scheduler worker or registry.

Functions

dispatch_custom_aggregation_task

dispatch_custom_observation_aggregation

dispatch_custom_sample_aggregation

methods_pls_predict_feature_content_fingerprint

Compute the published X-only content identity for a Methods PLS cohort.

plan_oof_partition_mode

The OOF FoldPartitionMode for a plan: its fold set’s mode, or Partition (the clean-OOF default) when the plan carries no fold set. Used to make the cross-fold scoring gate mode-aware so Resampled (ShuffleSplit / repeated CV) campaigns, where a sample is validated in several folds, are not rejected by the Partition exactly-once uniqueness rule.

refit_artifact_input_key

select_best_operator_variant_by_cv

Pick the best OPERATOR variant of an operator-generator UNION plan by its cross-validation score.

select_best_operator_variant_from_models

Route operator-SELECT from the operator-variant models lowered off a pipeline DSL (compile_operator_variant_models).

select_best_variant_by_cv

Pick the best variant of a multi-variant plan by its cross-validation score, natively.

select_best_variant_outcome_by_cv

Select the best plan variant and retain the exact decision produced by the shared native ranking pass.

select_best_variant_outcome_by_cv_for_target

Select a plan variant using only the cross-fold OOF average emitted by one explicitly resolved score-target producer. All producers’ validation reports remain retained in the returned outcome for audit.