diff --git a/src/worker/job_worker.rs b/src/worker/job_worker.rs
index 9ba9ff6..c37f8b5 100644
--- a/src/worker/job_worker.rs
+++ b/src/worker/job_worker.rs
@@ -312,6 +312,12 @@ impl JobWorker {
             .init_processing_status(&job.uuid, processor_names.clone(), total_frames)
             .await?;
 
+        // Clear any stale PipelineProgress from previous jobs
+        let progress_key = format!("{}progress:{}:pipeline", crate::core::config::REDIS_KEY_PREFIX.as_str(), job.uuid);
+        if let Ok(mut conn) = self.redis.get_conn().await {
+            let _: Option<String> = redis::cmd("DEL").arg(&progress_key).query_async(&mut conn).await.ok();
+        }
+
         self.db
             .update_job_status(job.id, MonitorJobStatus::Running)
             .await?;