From 94c1495a4ae4e933c2238a13414bb7a10e76f765 Mon Sep 17 00:00:00 2001 From: sylveondeko Date: Tue, 16 Apr 2024 19:54:39 -0400 Subject: [PATCH] fuck parallel --- .../Utility/Services/MessageRepeaterService.cs | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) diff --git a/src/Mewdeko/Modules/Utility/Services/MessageRepeaterService.cs b/src/Mewdeko/Modules/Utility/Services/MessageRepeaterService.cs index c712a92b7..63f6ad701 100644 --- a/src/Mewdeko/Modules/Utility/Services/MessageRepeaterService.cs +++ b/src/Mewdeko/Modules/Utility/Services/MessageRepeaterService.cs @@ -30,21 +30,16 @@ public async Task OnReadyAsync() await using var uow = db.GetDbContext(); var repeaters = new Dictionary>(); - await Parallel.ForEachAsync(client.Guilds, new ParallelOptions - { - MaxDegreeOfParallelism = 8 - }, async (gc, cancellationToken) => + foreach (var gc in client.Guilds) { try { var config = await gss.GetGuildConfig(gc.Id); var idToRepeater = config.GuildRepeaters - .Where(gr => gr.DateAdded != null) - .Select(gr => new KeyValuePair( - gr.Id, - new RepeatRunner(client, gc, gr, this))) - .GroupBy(x => x.Key) - .ToDictionary(g => g.Key, g => g.First().Value) + .Where(gr => gr.DateAdded is not null) + .Select(gr => + new KeyValuePair(gr.Id, new RepeatRunner(client, gc, gr, this))) + .ToDictionary(x => x.Key, y => y.Value) .ToConcurrent(); repeaters.TryAdd(gc.Id, idToRepeater); @@ -53,7 +48,7 @@ public async Task OnReadyAsync() { Log.Error(ex, "Failed to load repeaters on Guild {0}", gc.Id); } - }); + } Repeaters = repeaters.ToConcurrent(); RepeaterReady = true;