missions: cargo fmt for run-output endpoint
This commit is contained in:
@@ -378,20 +378,18 @@ pub async fn get_run_output(
|
|||||||
let run = cm_db::repo::topology_runs::status(&state.pool, id, user.workspace_id).await?;
|
let run = cm_db::repo::topology_runs::status(&state.pool, id, user.workspace_id).await?;
|
||||||
let cp = run.checkpoint.unwrap_or(serde_json::Value::Null);
|
let cp = run.checkpoint.unwrap_or(serde_json::Value::Null);
|
||||||
let totals = cp.get("totals").cloned().unwrap_or(serde_json::Value::Null);
|
let totals = cp.get("totals").cloned().unwrap_or(serde_json::Value::Null);
|
||||||
let turns = totals
|
let turns = totals.get("turns").and_then(|v| v.as_u64()).unwrap_or(0);
|
||||||
.get("turns")
|
let tokens = totals.get("tokens").and_then(|v| v.as_u64()).unwrap_or(0);
|
||||||
.and_then(|v| v.as_u64())
|
|
||||||
.unwrap_or(0);
|
|
||||||
let tokens = totals
|
|
||||||
.get("tokens")
|
|
||||||
.and_then(|v| v.as_u64())
|
|
||||||
.unwrap_or(0);
|
|
||||||
let records_count = cp
|
let records_count = cp
|
||||||
.get("records")
|
.get("records")
|
||||||
.and_then(|v| v.as_array())
|
.and_then(|v| v.as_array())
|
||||||
.map(|a| a.len())
|
.map(|a| a.len())
|
||||||
.unwrap_or(0);
|
.unwrap_or(0);
|
||||||
let outputs_raw = cp.get("outputs").and_then(|v| v.as_array()).cloned().unwrap_or_default();
|
let outputs_raw = cp
|
||||||
|
.get("outputs")
|
||||||
|
.and_then(|v| v.as_array())
|
||||||
|
.cloned()
|
||||||
|
.unwrap_or_default();
|
||||||
let outputs = outputs_raw
|
let outputs = outputs_raw
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.take(OUTPUT_LIST_MAX)
|
.take(OUTPUT_LIST_MAX)
|
||||||
|
|||||||
Reference in New Issue
Block a user