Review normalize stage architecture

This commit is contained in:
2026-05-10 21:47:21 +00:00
parent 1f4c06a202
commit 65937dfa9e
2 changed files with 3 additions and 3 deletions

View File

@@ -16,8 +16,8 @@ Implemented now:
Not implemented yet: Not implemented yet:
- real `archive` behavior - `archive` stage behavior
- real `notify` behavior - `notify` stage behavior
- additional analyze artifacts beyond `session_recap` - additional analyze artifacts beyond `session_recap`
- generic DAG orchestration - generic DAG orchestration

View File

@@ -23,7 +23,7 @@ func TestStageMarkHelpers(t *testing.T) {
} }
succeededAt := runningAt.Add(2 * time.Minute) succeededAt := runningAt.Add(2 * time.Minute)
outputs := []ArtifactRecord{{Kind: "processed_transcript", LocalPath: "transcripts/processed.json"}} outputs := []ArtifactRecord{{Kind: "transcript_processed", LocalPath: "transcripts/processed.json"}}
m.MarkStageSucceeded("transcribe", succeededAt, outputs) m.MarkStageSucceeded("transcribe", succeededAt, outputs)
if stage.Status != StatusSucceeded { if stage.Status != StatusSucceeded {
t.Fatalf("status = %q, want %q", stage.Status, StatusSucceeded) t.Fatalf("status = %q, want %q", stage.Status, StatusSucceeded)