Allow disabling processors via envvar because kubernetes cruft

ppy · Nov 15, 2023 · ae361db · ae361db
1 parent 87a0efe
commit ae361db
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/osu.Server.Queues.ScoreStatisticsProcessor/Commands/Queue/WatchQueueCommand.cs b/osu.Server.Queues.ScoreStatisticsProcessor/Commands/Queue/WatchQueueCommand.cs
@@ -19,6 +19,16 @@ public class WatchQueueCommand
 
         public Task<int> OnExecuteAsync(CancellationToken cancellationToken)
         {
+            string? disabledProcessorsEnv = Environment.GetEnvironmentVariable("DISABLED_PROCESSORS");
+
+            if (!string.IsNullOrEmpty(disabledProcessorsEnv))
+            {
+                if (!string.IsNullOrEmpty(DisabledProcessors))
+                    throw new ArgumentException("Attempted to specify disabled processors via parameter and environment at the same time");
+
+                DisabledProcessors = disabledProcessorsEnv;
+            }
+
             ScoreStatisticsQueueProcessor queue = new ScoreStatisticsQueueProcessor(DisabledProcessors.Split(',', StringSplitOptions.TrimEntries | StringSplitOptions.RemoveEmptyEntries));
 
             queue.Run(cancellationToken);