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

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 and params fingerprint) 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

NodeResult

NodeTask

ParallelScheduler

PredictionCacheMaterializationRecord

PredictionCacheMaterializationRequest

PredictionInputSpec

RunContext

RuntimeControllerRegistry

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.

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

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

NODE_RESULT_SCHEMA_ID

NODE_RESULT_SCHEMA_VERSION

NODE_TASK_SCHEMA_ID

NODE_TASK_SCHEMA_VERSION

Traits

RuntimeArtifactStore

RuntimeController

RuntimeDataProvider

RuntimePredictionCacheStore

Functions

dispatch_custom_aggregation_task

dispatch_custom_observation_aggregation

dispatch_custom_sample_aggregation

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.