Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ All notable changes to TEPP are documented here. The format follows Keep a Chang

## [Unreleased]

- **Pareto candidate-`K` analysis-run profile**: cutoff-safe `pareto_candidate_k_v1` binds `select_candidate_k` and selected-`K` RMSE and refuses LLM-vote authority (`analysis_engine`). Not Schwarz fitted selection, not a Bayesian sampler, and not implemented-main.
- Removed the repository-local hourly PR-maintenance caller now covered by the central required scheduler, retired stale workflow registrations, narrowed documentation triggers, keyed PR concurrency by fixed workflow name, repository, and pull-request number without cancelling non-PR runs, and combined line/branch coverage on one sequential runner while preserving both 100% gates and diagnostics.

- `event_core` adds bounded Allen interval-consistency classification, atomic path-consistency closure, contradiction/resource refusals, and an explicit dependency-error fallback without claiming unrestricted global satisfiability.
Expand Down
1 change: 1 addition & 0 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions crates/analysis_engine/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ publish = false

[dependencies]
event_core = { path = "../event_core", version = "0.2.0" }
model_selection = { path = "../model_selection", version = "0.2.0" }
serde = { workspace = true }
serde_json = { workspace = true }
sha2 = { workspace = true }
Expand Down
42 changes: 40 additions & 2 deletions crates/analysis_engine/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,13 +8,17 @@
//! through [`tepp_api`]. It deliberately does not claim latent-variable or topic
//! estimation authority; those estimators remain separate scientific crates.
//! estimation authority; it invokes estimators through their scientific crate
//! contracts and preserves their artifact meaning.
//! contracts and preserves their artifact meaning. Pareto candidate-`K`
//! selection is invoked through [`model_selection`] and is not a Bayesian
//! sampler.

mod case_deletion_refit;
mod lineage_criterion;
mod pareto_candidate_k_artifact;
mod topic_context_posterior;
mod topic_lineage_artifact;

use model_selection::ModelSelectionError;
use serde::Serialize;
use sha2::{Digest, Sha256};
use std::collections::BTreeSet;
Expand Down Expand Up @@ -46,6 +50,13 @@ pub use lineage_criterion::{
LineageCriterionFit, LineageCriterionFitError, LineageCriterionObservation,
fit_lineage_criterion_posteriors,
};
/// Pareto candidate-`K` artifact and execution contracts from this engine.
pub use pareto_candidate_k_artifact::{
PARETO_CANDIDATE_K_ARTIFACT_BYTE_LIMIT, PARETO_CANDIDATE_K_ARTIFACT_SCHEMA_VERSION,
PARETO_CANDIDATE_K_MODEL_CONTRACT_VERSION, PARETO_CANDIDATE_K_OUTPUT_PROFILE,
ParetoCandidateKArtifact, ParetoCandidateKExecution, ParetoCandidateKInput,
execute_pareto_candidate_k_run,
};
/// Bounded posterior topic-context producer contract and record types.
pub use topic_context_posterior::{
TOPIC_CONTEXT_POSTERIOR_BYTE_LIMIT, TOPIC_CONTEXT_POSTERIOR_SCHEMA_VERSION,
Expand Down Expand Up @@ -248,6 +259,10 @@ pub enum AnalysisEngineError {
TopicMeasurement(TopicMeasurementError),
/// A topic-lineage artifact violated its bounded schema or count invariants.
InvalidTopicLineageArtifact,
/// A model-selection gate rejected the offered candidates or method.
ModelSelection(ModelSelectionError),
/// A Pareto candidate-`K` artifact violated its bounded schema or counts.
InvalidParetoCandidateKArtifact,
}

impl fmt::Display for AnalysisEngineError {
Expand All @@ -262,6 +277,8 @@ impl fmt::Display for AnalysisEngineError {
Self::LimitExceeded => "analysis corpus exceeded its execution bound",
Self::TopicMeasurement(error) => return error.fmt(formatter),
Self::InvalidTopicLineageArtifact => "invalid topic lineage artifact",
Self::ModelSelection(error) => return error.fmt(formatter),
Self::InvalidParetoCandidateKArtifact => "invalid pareto candidate-k artifact",
};
formatter.write_str(message)
}
Expand All @@ -281,6 +298,12 @@ impl From<TopicMeasurementError> for AnalysisEngineError {
}
}

impl From<ModelSelectionError> for AnalysisEngineError {
fn from(error: ModelSelectionError) -> Self {
Self::ModelSelection(error)
}
}

/// Execute the cutoff-safe temporal evidence readiness analysis.
///
/// Evidence whose `available_time` is later than the request cutoff is excluded
Expand Down Expand Up @@ -413,7 +436,8 @@ mod tests {
use super::{
ANALYSIS_ARTIFACT_SCHEMA_VERSION, ANALYSIS_STATISTIC_COUNT, AnalysisCorpus,
AnalysisEngineError, AnalysisEvidenceUnit, MAX_ANALYSIS_IDENTIFIER_BYTES,
MAX_EVIDENCE_UNITS, TopicMeasurementError, add_membership_count, execute_analysis_run,
MAX_EVIDENCE_UNITS, ModelSelectionError, TopicMeasurementError, add_membership_count,
execute_analysis_run,
};
use temporal_core::{AvailableTime, EventTime};
use tepp_api::{AnalysisRunAccepted, AnalysisRunRequest, AnalysisRunTerminalState, ApiError};
Expand Down Expand Up @@ -681,6 +705,14 @@ mod tests {
AnalysisEngineError::InvalidTopicLineageArtifact,
"invalid topic lineage artifact",
),
(
AnalysisEngineError::InvalidParetoCandidateKArtifact,
"invalid pareto candidate-k artifact",
),
(
AnalysisEngineError::ModelSelection(ModelSelectionError::EmptyCandidateSet),
"empty model-selection candidate set",
),
];
for (error, message) in messages {
assert_eq!(error.to_string(), message);
Expand All @@ -689,6 +721,12 @@ mod tests {
assert_eq!(converted.to_string(), "invalid API wire payload");
let from_topic: AnalysisEngineError = TopicMeasurementError::DidNotConverge.into();
assert_eq!(from_topic.to_string(), "topic estimator did not converge");
let from_selection: AnalysisEngineError =
ModelSelectionError::LlmVoteIsNotStatisticalAuthority.into();
assert_eq!(
from_selection.to_string(),
"llm vote is not statistical authority"
);
assert_eq!(
add_membership_count(u64::MAX, 1),
Err(AnalysisEngineError::ArithmeticOverflow)
Expand Down
Loading
Loading