fix: update PipelineProgress when job completes via essential_completed path
When a job completes via the essential_completed branch (all essential processors done but some non-essential failed), the PipelineProgress was not being updated to 100%, causing a discrepancy where the status showed 'completed' but progress showed <100%. Now PipelineProgress.mark_completed() is called in both completion paths.
This commit is contained in:
@@ -1977,6 +1977,11 @@ impl JobWorker {
|
|||||||
|
|
||||||
self.redis.delete_worker_job(uuid).await?;
|
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!(
|
info!(
|
||||||
"Job {} completed with {} non-essential failures",
|
"Job {} completed with {} non-essential failures",
|
||||||
job_id,
|
job_id,
|
||||||
|
|||||||
Reference in New Issue
Block a user