We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a39fa24 commit 6265f2eCopy full SHA for 6265f2e
1 file changed
storage/posix/antispam/badger.go
@@ -23,6 +23,7 @@ import (
23
"errors"
24
"fmt"
25
"iter"
26
+ "os"
27
"sync/atomic"
28
"time"
29
@@ -261,7 +262,12 @@ func (f *follower) Follow(ctx context.Context, lr tessera.LogReader) {
261
262
// Our view of the log is out of date, update it
263
logSize, err = lr.IntegratedSize(ctx)
264
if err != nil {
- workDone = true
265
+ if errors.Is(err, os.ErrNotExist) {
266
+ // The log probably just hasn't completed its first integration yet, so break out of here
267
+ // and go back to sleep for a bit to avoid spamming errors into the log and scaring operators.
268
+ workDone = false
269
+ return nil
270
+ }
271
return fmt.Errorf("populate: IntegratedSize(): %v", err)
272
}
273
switch {
0 commit comments