diff --git a/src/worker/job_worker.rs b/src/worker/job_worker.rs
index ff3de7f..a5b69cb 100644
--- a/src/worker/job_worker.rs
+++ b/src/worker/job_worker.rs
@@ -1977,6 +1977,11 @@ impl JobWorker {
 
             self.redis.delete_worker_job(uuid).await?;
 
+            // Update PipelineProgress to completed
+            let mut pp = PipelineProgress::new(uuid);
+            pp.mark_completed();
+            publish_pipeline_progress(self.redis.as_ref(), uuid, &pp).await;
+
             info!(
                 "Job {} completed with {} non-essential failures",
                 job_id,