Skip to content

Commit 36fa594

Browse files
committed
Add finish check for runner
1 parent ac51417 commit 36fa594

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

pkg/runner/chunk_runner.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ import (
2929
"net/http"
3030
"os"
3131
"reflect"
32+
"slices"
3233
"sort"
3334
"strconv"
3435
"strings"
@@ -673,6 +674,13 @@ func (r *ChunkRunner) process(continues <-chan struct{}, chunk *v1alpha1.Chunk)
673674
return
674675
}
675676

677+
if slices.Contains(etags, "") {
678+
r.unmarkRecord(chunk.Name)
679+
err := fmt.Errorf("destinations failed to return ETag")
680+
s.handleProcessErrorAndRetryable("MissingETag", err)
681+
return
682+
}
683+
676684
r.handleSha256AndFinalize(continues, chunk, s, swmr, etags)
677685
}
678686

0 commit comments

Comments
 (0)