From 70e6915246caefeabd3a3fb0121726282fa9010f Mon Sep 17 00:00:00 2001 From: Accusys Date: Mon, 20 Jul 2026 21:59:53 +0800 Subject: [PATCH] fix: remove error status handling that caused TKG to build without face_track nodes --- src/worker/job_worker.rs | 21 +-------------------- 1 file changed, 1 insertion(+), 20 deletions(-) diff --git a/src/worker/job_worker.rs b/src/worker/job_worker.rs index e1ea7d4..d9fc326 100644 --- a/src/worker/job_worker.rs +++ b/src/worker/job_worker.rs @@ -1375,13 +1375,6 @@ impl JobWorker { ); return true; } - if status == "error" { - tracing::error!( - "[Ingestion] Face trace failed for {} - marking as done (with error)", - uuid - ); - return true; - } } if let Some(traces) = traced_data.get("traces") { @@ -1933,19 +1926,7 @@ impl JobWorker { .await; } Err(e) => { - error!("❌ Face trace + DB store failed for {}: {}", uuid_clone, e); - // Write fallback face_traced.json to unblock ingestion check - let output_dir = std::env::var("MOMENTRY_OUTPUT_DIR") - .unwrap_or_else(|_| "/Users/accusys/momentry/output".to_string()); - let fallback_path = format!("{}/{}.face_traced.json", output_dir, uuid_clone); - let fallback_content = serde_json::json!({ - "status": "error", - "error": e.to_string(), - "traces": {} - }); - if let Err(write_err) = std::fs::write(&fallback_path, fallback_content.to_string()) { - error!("Failed to write fallback face_traced.json for {}: {}", uuid_clone, write_err); - } + error!("❌ Face trace + DB store failed for {}: {}", uuid_clone, e) } } });