notfire/Iceshrimp.NET
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[backend/core] Switch to IQueryable<T>.AsChunkedAsyncEnumerable() in MediaCleanupTask

Browse source
This commit is contained in:
Laura Hausmann 2024-09-23 00:23:33 +02:00
parent 1d9864a214
commit ca2c4f35ab
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
Iceshrimp.Backend/Core/Tasks/MediaCleanupTask.cs
View file

@ -1,6 +1,7 @@
using System.Diagnostics.CodeAnalysis;
using Iceshrimp.Backend.Core.Configuration;
using Iceshrimp.Backend.Core.Database;
using Iceshrimp.Backend.Core.Extensions;
using Iceshrimp.Backend.Core.Queues;
using Iceshrimp.Backend.Core.Services;
using Microsoft.EntityFrameworkCore;
@ -33,7 +34,7 @@ public class MediaCleanupTask : ICronTask
var cnt = await fileIds.CountAsync();
logger.LogInformation("Expiring {count} files...", cnt);
await foreach (var fileId in fileIds.AsAsyncEnumerable())
await foreach (var fileId in fileIds.AsChunkedAsyncEnumerable(50))
{
await queueService.BackgroundTaskQueue.EnqueueAsync(new DriveFileDeleteJobData
{