Skip to main content

Module pipeline

Module pipeline 

Source
Expand description

The post-dispatch processing chain: stateless JSON-in/JSON-out stages.

Chain order: record-runsfill-transcriptsdetect-stray-writesgradeaggregate. Each stage reads JSON/JSONL artifacts from an iteration directory and writes JSON back; no stage pipes to another in-memory, so any stage can be run (and re-run) standalone.

Re-exports§

pub use aggregate::Benchmark;
pub use aggregate::aggregate;
pub use detect_stray_writes::StrayFinding;
pub use detect_stray_writes::StrayWritesReport;
pub use detect_stray_writes::detect_live_source_reads;
pub use detect_stray_writes::detect_stray_writes;
pub use detect_stray_writes::detect_stray_writes_report;
pub use error::PipelineError;
pub use fill_transcripts::FillTranscriptsResult;
pub use fill_transcripts::fill_transcripts;
pub use grade::GradeContext;
pub use grade::emit_judge_tasks;
pub use grade::finalize;
pub use grade::finalize;
pub use record_runs::RecordRunsResult;
pub use record_runs::record_runs;
pub use slots::RunSlot;
pub use slots::run_slots;

Modules§

aggregate
Stage 5 — aggregate.
detect_stray_writes
Stage 3 — detect-stray-writes.
error
Shared error type for the pipeline stages.
fill_transcripts
Stage 2 — fill-transcripts.
grade
Stage 4 — grade.
io
Shared JSON read/write helpers for the pipeline stages.
record_runs
Stage 1 — record-runs.
slots
Run-slot enumeration for a condition cell.