diff --git a/internal/service/webhook.go b/internal/service/webhook.go
index 0165194..ddc44e0 100644
--- a/internal/service/webhook.go
+++ b/internal/service/webhook.go
@@ -3,7 +3,6 @@ package service
 import (
 	"amocrm/internal/models"
 	"context"
-	"database/sql"
 	"errors"
 	"go.uber.org/zap"
 	"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/pj_errors"
@@ -24,7 +23,7 @@ func (s *Service) WebhookCreate(ctx context.Context, req ParamsWebhookCreate) er
 		return err
 	}
 
-	if err == sql.ErrNoRows {
+	if errors.Is(err, pj_errors.ErrNotFound) {
 		message := models.KafkaMessage{
 			AccountID:  req.AccountID,
 			AuthCode:   req.Code,