From 78077ae454845d823e89d7a8f77ba1fb5231c066 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Fri, 14 Jul 2023 11:03:25 -0400 Subject: [PATCH] Make sure errors are logged for flatstore reader --- ers/flatstore.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/ers/flatstore.go b/ers/flatstore.go index 48031645b..a05b7e54a 100644 --- a/ers/flatstore.go +++ b/ers/flatstore.go @@ -159,8 +159,10 @@ func (rdr *FlatstoreER) processFile(fPath, fName string) (err error) { } else { pr, err := NewUnpairedRecord(record, rdr.Config().Timezone, fName) if err != nil { - fmt.Sprintf("<%s> Converting row : <%s> to unpairedRecord , ignoring due to error: <%s>", - utils.ERs, record, err.Error()) + utils.Logger.Err( + fmt.Sprintf("<%s> Converting row : <%s> to unpairedRecord , ignoring due to error: <%s>", + utils.ERs, record, err.Error()), + ) continue } if val, has := rdr.cache.Get(pr.OriginID); !has { @@ -170,8 +172,10 @@ func (rdr *FlatstoreER) processFile(fPath, fName string) (err error) { pair := val.(*UnpairedRecord) record, err = pairToRecord(pair, pr) if err != nil { - fmt.Sprintf("<%s> Merging unpairedRecords : <%s> and <%s> to record , ignoring due to error: <%s>", - utils.ERs, utils.ToJSON(pair), utils.ToJSON(pr), err.Error()) + utils.Logger.Err( + fmt.Sprintf("<%s> Merging unpairedRecords : <%s> and <%s> to record , ignoring due to error: <%s>", + utils.ERs, utils.ToJSON(pair), utils.ToJSON(pr), err.Error()), + ) continue } rdr.cache.Remove(pr.OriginID)