fix(evolution): capture Close() error on write file in appendJSONLRecords

This commit is contained in:
程智超0668000959 2026-06-14 23:42:44 +08:00
parent cf67dd3851
commit 7d71a4d93f

View file

@ -88,7 +88,11 @@ func (s *Store) appendJSONLRecords(ctx context.Context, path string, records []L
if err != nil { if err != nil {
return err return err
} }
defer f.Close() defer func() {
if closeErr := f.Close(); closeErr != nil && err == nil {
err = closeErr
}
}()
enc := json.NewEncoder(f) enc := json.NewEncoder(f)
for _, record := range records { for _, record := range records {