diff --git a/internal/workers/queueUpdater/queue_updater.go b/internal/workers/queueUpdater/queue_updater.go
index 136177b..9c85e58 100644
--- a/internal/workers/queueUpdater/queue_updater.go
+++ b/internal/workers/queueUpdater/queue_updater.go
@@ -165,32 +165,34 @@ func (wc *QueueUpdater) processMessages(ctx context.Context, message models.Kafk
 			return err
 		}
 
-		// обновляем информацию о пользователях
-		err = wc.methods.CheckUsers(ctx, newTokens)
-		if err != nil {
-			wc.logger.Error("error update users information", zap.Error(err))
-			return err
-		}
+		if len(newTokens) > 0 {
+			// обновляем информацию о пользователях
+			err = wc.methods.CheckUsers(ctx, newTokens)
+			if err != nil {
+				wc.logger.Error("error update users information", zap.Error(err))
+				return err
+			}
 
-		// обновляем информацию о pipelines и их steps
-		err = wc.methods.CheckPipelinesAndSteps(ctx, newTokens)
-		if err != nil {
-			wc.logger.Error("error updating users pipelines and users pipelines-steps", zap.Error(err))
-			return err
-		}
+			// обновляем информацию о pipelines и их steps
+			err = wc.methods.CheckPipelinesAndSteps(ctx, newTokens)
+			if err != nil {
+				wc.logger.Error("error updating users pipelines and users pipelines-steps", zap.Error(err))
+				return err
+			}
 
-		// обновляем информацию о tags
-		err = wc.methods.CheckTags(ctx, newTokens)
-		if err != nil {
-			wc.logger.Error("error updating users tags", zap.Error(err))
-			return err
-		}
+			// обновляем информацию о tags
+			err = wc.methods.CheckTags(ctx, newTokens)
+			if err != nil {
+				wc.logger.Error("error updating users tags", zap.Error(err))
+				return err
+			}
 
-		// обновляем информацию о fields
-		err = wc.methods.CheckFields(ctx, newTokens)
-		if err != nil {
-			wc.logger.Error("error updating users fields", zap.Error(err))
-			return err
+			// обновляем информацию о fields
+			err = wc.methods.CheckFields(ctx, newTokens)
+			if err != nil {
+				wc.logger.Error("error updating users fields", zap.Error(err))
+				return err
+			}
 		}
 	case models.RuleCheck:
 		token, err := wc.methods.GetTokenByID(ctx, message.AccountID)