Add skip of old ES schemas

ppy · Dec 21, 2023 · aef8f7c · aef8f7c
1 parent 6f5ce24
commit aef8f7c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/osu.Server.Queues.ScoreStatisticsProcessor/ElasticQueueProcessor.cs b/osu.Server.Queues.ScoreStatisticsProcessor/ElasticQueueProcessor.cs
@@ -17,8 +17,14 @@ public ElasticQueuePusher()
             using (var redis = RedisAccess.GetConnection())
             {
                 var schemas = redis.GetActiveSchemas();
+
                 foreach (var schema in schemas)
-                    processors.Add(new ElasticQueueProcessor(schema));
+                {
+                    // Old schemas that don't have the prefix in the active list.
+                    // We don't want to push to them.
+                    if (schema.Length <= 2)
+                        processors.Add(new ElasticQueueProcessor(schema));
+                }
             }
         }