Skip to content

Commit e45cc54

Browse files
committed
fix: improve error handling in CleanCountedLogs to create default data retention file if retrieval fails
1 parent 33ec951 commit e45cc54

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

agent/logservice/processor.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -174,8 +174,16 @@ func (l *LogProcessor) CleanCountedLogs() {
174174
for range ticker.C {
175175
dataRetention, err := GetDataRetention()
176176
if err != nil {
177-
utils.Logger.ErrorF("error getting data retention: %s", err)
178-
continue
177+
utils.Logger.ErrorF("error getting data retention: %s, creating default retention file", err)
178+
if err := SetDataRetention(""); err != nil {
179+
utils.Logger.ErrorF("error creating default data retention: %s", err)
180+
continue
181+
}
182+
dataRetention, err = GetDataRetention()
183+
if err != nil {
184+
utils.Logger.ErrorF("error reading newly created data retention: %s", err)
185+
continue
186+
}
179187
}
180188
l.db.Lock()
181189
_, err = l.db.DeleteOld(&models.Log{}, dataRetention)

0 commit comments

Comments
 (0)