Skip to content

Commit cec8a6b

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

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

pkg/runner/chunk_runner.go

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

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

0 commit comments

Comments
 (0)