Retain dirty runtime failures as partial progress

apps/decodex/src/orchestrator/daemon.rs

@@ -1290,6 +1290,7 @@ where
 			issue_identifier: issue.identifier.clone(),
 			run_id: child.run_id.to_owned(),
 			worktree_path: worktree_path.clone(),
+			source_error_class: None,
 		})
 	} else {
 		Report::msg(format!(

apps/decodex/src/orchestrator/execution.rs

@@ -71,6 +71,7 @@ struct TerminalFailureLifecycle<'a> {
 	target_state: &'a str,
 	worktree_path: &'a str,
 	manual_attention_requested: bool,
+	retained_source_error_class: Option<&'a str>,
 }
 
 struct RunStartedLifecycleFields<'a> {
@@ -450,13 +451,21 @@ fn terminal_failure_lifecycle_event(
 	record.next_action = Some(failure.next_action.to_owned());
 
 	if retained_partial_progress {
-		record.blockers = Some(vec![String::from(
-			"Retained tracked worktree changes require operator recovery.",
-		)]);
-		record.evidence = Some(vec![format!(
+		let mut evidence = vec![format!(
 			"Attempt {} stopped with tracked worktree changes retained.",
 			issue_run.attempt_number
+		)];
+
+		if let Some(source_error_class) = failure.retained_source_error_class {
+			evidence.push(format!(
+				"Source failure class `{source_error_class}` was preserved for recovery context."
+			));
+		}
+
+		record.blockers = Some(vec![String::from(
+			"Retained tracked worktree changes require operator recovery.",
 		)]);
+		record.evidence = Some(evidence);
 		record.summary = Some(String::from("Decodex retained partial progress and needs attention."));
 		record.terminal_path = Some(String::from("retained_partial_progress"));
 	} else {
@@ -1626,7 +1635,7 @@ fn retained_partial_progress_error(
 	issue_run: &IssueRunPlan,
 	worktree_path: &str,
 ) -> Option<Report> {
-	if terminal_failure_has_specific_error_class(error)
+	if retained_progress_should_defer_to_terminal_intent(error)
 		|| !worktree_has_tracked_changes(&issue_run.worktree.path)
 	{
 		return None;
@@ -1636,20 +1645,48 @@ fn retained_partial_progress_error(
 		issue_identifier: issue_run.issue.identifier.clone(),
 		run_id: issue_run.run_id.clone(),
 		worktree_path: worktree_path.to_owned(),
+		source_error_class: retained_progress_source_error_class(error).map(ToOwned::to_owned),
 	}))
 }
 
-fn terminal_failure_has_specific_error_class(error: &Report) -> bool {
+fn retained_progress_should_defer_to_terminal_intent(error: &Report) -> bool {
 	error.downcast_ref::<ManualAttentionRequested>().is_some()
 		|| error.downcast_ref::<ReviewHandoffNeedsAttention>().is_some()
 		|| error.downcast_ref::<RetainedPartialProgress>().is_some()
-		|| error.downcast_ref::<AgentGitCredentialsUnavailable>().is_some()
-		|| error.downcast_ref::<AppServerCapabilityPreflightFailure>().is_some()
-		|| error.downcast_ref::<AppServerHomePreflightFailure>().is_some()
-		|| error.downcast_ref::<AppServerTransportFailure>().is_some()
-		|| error.downcast_ref::<AppServerTurnFailure>().is_some()
+		|| error.downcast_ref::<RetainedReviewNeedsAttention>().is_some()
 		|| error.downcast_ref::<ReviewPolicyStopRequested>().is_some()
-		|| error.downcast_ref::<RepoGateFailure>().is_some()
+}
+
+fn retained_progress_source_error_class(error: &Report) -> Option<&'static str> {
+	if let Some(app_server_failure) = error.downcast_ref::<AppServerZeroEvidenceStartFailure>() {
+		Some(app_server_failure.error_class())
+	} else if error.downcast_ref::<StalledRunNeedsAttention>().is_some() {
+		Some("stalled_run_detected")
+	} else if error.downcast_ref::<AgentGitCredentialsUnavailable>().is_some() {
+		Some("github_credentials_unavailable")
+	} else if let Some(app_server_failure) =
+		error.downcast_ref::<AppServerCapabilityPreflightFailure>()
+	{
+		Some(app_server_failure.error_class())
+	} else if let Some(app_server_failure) =
+		error.downcast_ref::<AppServerHomePreflightFailure>()
+	{
+		Some(app_server_failure.error_class())
+	} else if let Some(app_server_failure) =
+		error.downcast_ref::<AppServerTransportFailure>()
+	{
+		Some(app_server_failure.error_class())
+	} else if let Some(app_server_failure) =
+		error.downcast_ref::<AppServerDynamicToolFailure>()
+	{
+		Some(app_server_failure.error_class())
+	} else if let Some(app_server_failure) = error.downcast_ref::<AppServerTurnFailure>() {
+		Some(app_server_failure.error_class())
+	} else if let Some(repo_gate_failure) = error.downcast_ref::<RepoGateFailure>() {
+		Some(repo_gate_failure.error_class())
+	} else {
+		None
+	}
 }
 
 fn write_retry_schedule_marker_for_runtime_retry(
@@ -1764,6 +1801,9 @@ where
 	let (error_class, next_action) =
 		terminal_failure_comment_details(manual_attention_requested, error, &recovery_gate);
 	let pr_url = terminal_failure_pr_url(error);
+	let retained_source_error_class = error
+		.downcast_ref::<RetainedPartialProgress>()
+		.and_then(|partial_progress| partial_progress.source_error_class.as_deref());
 	let comment = format_terminal_failure_comment(
 		&issue_run.run_id,
 		issue_run.attempt_number,
@@ -1783,6 +1823,7 @@ where
 			target_state: terminal_failure_state_name,
 			worktree_path,
 			manual_attention_requested,
+			retained_source_error_class,
 		},
 	);
 	let projection = tracker::prepare_linear_execution_event_comment(

apps/decodex/src/orchestrator/reconciliation.rs

@@ -445,6 +445,7 @@ where
 			issue_identifier: action.issue.identifier.clone(),
 			run_id: action.run_attempt.run_id().to_owned(),
 			worktree_path,
+			source_error_class: Some(String::from("stalled_run_detected")),
 		}),
 	)?;
 

apps/decodex/src/orchestrator/tests/recovery/reconciliation.rs

@@ -1173,15 +1173,21 @@ fn stalled_run_reconciliation_reports_retained_partial_progress_for_dirty_worktr
 		"stalled"
 	);
 
-	let comments = tracker.comments.borrow();
+	assert_dirty_stalled_retained_progress_comments(&tracker.comments.borrow());
+}
 
+fn assert_dirty_stalled_retained_progress_comments(comments: &[String]) {
 	assert!(comments.iter().any(|comment| {
 		comment.contains("decodex retained partial progress and needs attention")
 			&& comment.contains("partial_progress_retained")
 			&& comment.contains("finish validation and PR handoff or reset the patch manually")
 			&& comment.contains(".worktrees/PUB-102")
 	}));
-	assert!(comments.iter().all(|comment| !comment.contains("stalled_run_detected")));
+	assert!(
+		comments
+			.iter()
+			.all(|comment| !comment.contains("- error_class: `stalled_run_detected`"))
+	);
 	assert!(comments.iter().all(|comment| !comment.contains("decodex run failed and needs attention")));
 
 	let ledger_event = comments
@@ -1212,6 +1218,15 @@ fn stalled_run_reconciliation_reports_retained_partial_progress_for_dirty_worktr
 				.any(|item| item.contains("tracked worktree changes retained"))),
 		"retained partial progress evidence should mention retained tracked changes"
 	);
+	assert!(
+		ledger_event
+			.evidence
+			.as_deref()
+			.is_some_and(|evidence| evidence
+				.iter()
+				.any(|item| item.contains("Source failure class `stalled_run_detected`"))),
+		"retained partial progress evidence should preserve the stalled source class"
+	);
 }
 
 #[test]