diff --git a/service/app/follow_change_puller.go b/service/app/follow_change_puller.go index 0e871ae..5006435 100644 --- a/service/app/follow_change_puller.go +++ b/service/app/follow_change_puller.go @@ -55,7 +55,15 @@ func (f *FollowChangePuller) Run(ctx context.Context) error { } tokens, err := f.queries.GetTokens.Handle(ctx, followChangeAggregate.Followee) - if err != nil { + if err != nil || len(tokens) == 0 { + f.logger.Error(). + WithField("followee", followChangeAggregate.Followee.Hex()). + WithError(err). + Message("error getting tokens for followee") + continue + } + + if len(tokens) == 0 { // Not one of our users, ignore continue }