fix: remove error status handling that caused TKG to build without face_track nodes
This commit is contained in:
@@ -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)
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user