mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-05-28 04:30:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(weed/worker/tasks): log dropped errors (#9057)

Browse Source
This commit is contained in:
Lars Lehtonen
2026-04-13 16:03:02 -07:00
committed by GitHub
parent 8f2a3d92bb
commit e0c361ec77
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
weed/worker/tasks/task_logger.go
View File

@@ -199,7 +199,10 @@ func (l *FileTaskLogger) LogProgress(progress float64, message string) {
}
l.writeLogEntry(entry)
l.saveMetadata() // Update metadata with new progress
// Update metadata with new progress
if err := l.saveMetadata(); err != nil {
glog.Warningf("Failed to save initial task metadata: %v", err)
}
}
// LogStatus logs task status change
@@ -216,7 +219,10 @@ func (l *FileTaskLogger) LogStatus(status string, message string) {
}
l.writeLogEntry(entry)
l.saveMetadata() // Update metadata with new status
// Update metadata with new status
if err := l.saveMetadata(); err != nil {
glog.Warningf("Failed to update metadata with new status: %v", err)
}
}
// LogWithFields logs a message with structured fields
@@ -263,7 +269,9 @@ func (l *FileTaskLogger) Close() error {
}
// Save final metadata
l.saveMetadata()
if err := l.saveMetadata(); err != nil {
glog.Warningf("Failed to save final task metadata: %v", err)
}
// Close log file
if l.logFile != nil {