fix: fix job duration unwrap crash

2026-08-21 00:02:23 +00:00 · 2025-10-01 15:35:07 +00:00
parent 52bf2eb9c1
commit 7e13bf4fb6
1 changed files with 4 additions and 4 deletions
@@ -691,10 +691,10 @@ pub async fn process_completed_job(
                    &job.workspace_id,
                    false,
                    Arc::new(serde_json::value::to_raw_value(&result).unwrap()),
-                    duration.map(|x| FlowJobDuration {
-                        started_at: job.started_at.unwrap(),
-                        duration_ms: x,
-                    }),
+                    duration.and_then(|d| job.started_at.map(|started_at| FlowJobDuration {
+                        started_at: started_at,
+                        duration_ms: d,
+                    })),
                    false,
                    &same_worker_tx.expect(SAME_WORKER_REQUIREMENTS).to_owned(),
                    &worker_dir,