diff --git a/src/ratings.py b/src/ratings.py
index 1cd64d4..9a2f88c 100644
--- a/src/ratings.py
+++ b/src/ratings.py
@@ -167,6 +167,7 @@ def process_rating_of_next_game() -> bool:
                 "FROM game_participants "
                 "INNER JOIN games "
                 "  ON games.id = game_participants.game_id "
+                "INNER JOIN variants ON games.variant_id = variants.id "
                 "WHERE user_id IN"
                 "  ("
                 "  SELECT game_participants.user_id FROM games "
@@ -175,8 +176,9 @@ def process_rating_of_next_game() -> bool:
                 "  WHERE games.id = %s"
                 "  )"
                 "AND league_id <= %s "
+                "AND rating_type = %s "
                 "GROUP BY user_id",
-                (game_id, league_id)
+                (game_id, league_id, rating_type)
                 )
     games_played = {}
     for (user_id, num_games) in cur.fetchall():