this repo has no description
better logging
authored by
Brian Olson
and committed by
Brian Olson
a3802a80
ef5b0b81
+3
-1
+3
-1
bgs/bgs.go
+3
-1
bgs/bgs.go
···
983
983
}
984
984
985
985
if err := bgs.repoman.HandleExternalUserEvent(ctx, host.ID, u.ID, u.Did, evt.Since, evt.Rev, evt.Blocks, evt.Ops); err != nil {
986
-
log.Warnw("failed handling event", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
987
986
988
987
if errors.Is(err, carstore.ErrRepoBaseMismatch) || ipld.IsNotFound(err) {
989
988
ai, lerr := bgs.Index.LookupUser(ctx, u.ID)
990
989
if lerr != nil {
990
+
log.Warnw("failed handling event, no user", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
991
991
return fmt.Errorf("failed to look up user %s (%d) (err case: %s): %w", u.Did, u.ID, err, lerr)
992
992
}
993
993
994
994
span.SetAttributes(attribute.Bool("catchup_queue", true))
995
995
996
+
log.Infow("failed handling event, catchup", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
996
997
return bgs.Index.Crawler.AddToCatchupQueue(ctx, host, ai, evt)
997
998
}
998
999
1000
+
log.Warnw("failed handling event", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
999
1001
return fmt.Errorf("handle user event failed: %w", err)
1000
1002
}
1001
1003