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]

- `analysis_engine` jointly binds posterior-draw OLS loading means (`recover_loading_point_estimate_mean`) and Rubin (1996) total variance (`combine_draw_level_ols_loadings`) to the `rubin_loading_uncertainty_v1` analysis-run output profile. Observations unavailable at the request cutoff are excluded; the digest-bound `tepp.rubin_loading_uncertainty.v1` artifact records the point-estimate mean and Rubin `Q̄`/`Ū`/`B`/`T` and refuses Mislevy person-level plausible-value claims. This is not a new ESEM/DSEM estimator, not CWC, not a Driver p.16 `std` restore, and not persistence.
- 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" }
psychometric_core = { path = "../psychometric_core", version = "0.2.0" }
serde = { workspace = true }
serde_json = { workspace = true }
sha2 = { workspace = true }
Expand Down
41 changes: 40 additions & 1 deletion 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. Rubin loading uncertainty
//! is invoked through [`psychometric_core`] and is not Mislevy person-level
//! plausible-value pooling.

mod case_deletion_refit;
mod lineage_criterion;
mod rubin_loading_artifact;
mod topic_context_posterior;
mod topic_lineage_artifact;

use psychometric_core::PsychometricError;
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,
};
/// Rubin loading-uncertainty artifact and execution contracts.
pub use rubin_loading_artifact::{
RUBIN_LOADING_ARTIFACT_BYTE_LIMIT, RUBIN_LOADING_ARTIFACT_SCHEMA_VERSION,
RUBIN_LOADING_MODEL_CONTRACT_VERSION, RUBIN_LOADING_OUTPUT_PROFILE, RubinLoadingObservation,
RubinLoadingUncertaintyArtifact, RubinLoadingUncertaintyExecution,
execute_rubin_loading_uncertainty_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 psychometric recovery rejected the offered coordinates.
Psychometric(PsychometricError),
/// A Rubin loading-uncertainty artifact violated its bounded schema.
InvalidRubinLoadingUncertaintyArtifact,
}

impl fmt::Display for AnalysisEngineError {
Expand All @@ -262,6 +277,10 @@ 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::Psychometric(error) => return error.fmt(formatter),
Self::InvalidRubinLoadingUncertaintyArtifact => {
"invalid Rubin loading-uncertainty artifact"
}
};
formatter.write_str(message)
}
Expand All @@ -281,6 +300,12 @@ impl From<TopicMeasurementError> for AnalysisEngineError {
}
}

impl From<PsychometricError> for AnalysisEngineError {
fn from(error: PsychometricError) -> Self {
Self::Psychometric(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 @@ -415,6 +440,7 @@ mod tests {
AnalysisEngineError, AnalysisEvidenceUnit, MAX_ANALYSIS_IDENTIFIER_BYTES,
MAX_EVIDENCE_UNITS, TopicMeasurementError, add_membership_count, execute_analysis_run,
};
use psychometric_core::PsychometricError;
use temporal_core::{AvailableTime, EventTime};
use tepp_api::{AnalysisRunAccepted, AnalysisRunRequest, AnalysisRunTerminalState, ApiError};

Expand Down Expand Up @@ -681,6 +707,14 @@ mod tests {
AnalysisEngineError::InvalidTopicLineageArtifact,
"invalid topic lineage artifact",
),
(
AnalysisEngineError::Psychometric(PsychometricError::InsufficientDraws),
"Rubin total variance requires at least two complete-data draws",
),
(
AnalysisEngineError::InvalidRubinLoadingUncertaintyArtifact,
"invalid Rubin loading-uncertainty artifact",
),
];
for (error, message) in messages {
assert_eq!(error.to_string(), message);
Expand All @@ -689,6 +723,11 @@ 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_psych: AnalysisEngineError = PsychometricError::InsufficientDraws.into();
assert_eq!(
from_psych.to_string(),
"Rubin total variance requires at least two complete-data draws"
);
assert_eq!(
add_membership_count(u64::MAX, 1),
Err(AnalysisEngineError::ArithmeticOverflow)
Expand Down
Loading
Loading