Update core/tasks/batchimport/execute.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
2026-01-17 21:25:49 +08:00
parent 441d944bc2
commit dceb3737f6
1 changed files with 2 additions and 0 deletions
--- a/core/tasks/batchimport/execute.go
+++ b/core/tasks/batchimport/execute.go
@@ -48,7 +48,9 @@ func (t *Task) Execute(ctx context.Context) error {
 				return err
 			}
 			if err != nil {
+				t.processingMu.Lock()
 				t.failed[elem.ID] = err
+				t.processingMu.Unlock()
 				logger.Errorf("Failed to process file %s: %v", elem.FileInfo.Name, err)
 			}
 			return nil