Skip to content

Commit ded5ca6

Browse files
committed
Update chunk progress status after processing global result values
1 parent 32f2500 commit ded5ca6

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

pkg/runner/chunk_runner.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -674,6 +674,12 @@ func (r *ChunkRunner) process(continues <-chan struct{}, chunk *v1alpha1.Chunk)
674674
return
675675
}
676676

677+
s.Update(func(ss *v1alpha1.Chunk) *v1alpha1.Chunk {
678+
if *gsr != nil {
679+
updateProgress(&ss.Status, &ss.Spec, *gsr, *gdrs)
680+
}
681+
})
682+
677683
chunk = s.Get()
678684
if chunk.Spec.Total > 0 && chunk.Status.Progress != chunk.Spec.Total {
679685
r.unmarkRecord(chunk.Name)

0 commit comments

Comments
 (0)