diff --git a/server/job/blacktagsProcessor.ts b/server/job/blacktagsProcessor.ts
index 2f4813a9..bdbc7451 100644
--- a/server/job/blacktagsProcessor.ts
+++ b/server/job/blacktagsProcessor.ts
@@ -178,7 +178,11 @@ class BlacktagProcessor implements RunnableScanner<StatusBase> {
       .innerJoinAndSelect(Blacklist, 'blist', 'blist.tmdbId = media.tmdbId')
       .where(`blist.blacktags IS NOT NULL`)
       .getMany();
-    await mediaRepository.remove(mediaToRemove); // This also deletes the blacklist entries via cascading
+
+    // Batch removes so the query doesn't get too large
+    for (let i = 0; i < mediaToRemove.length; i += 500) {
+      await mediaRepository.remove(mediaToRemove.slice(i, i + 500)); // This also deletes the blacklist entries via cascading
+    }
   }
 }