diff --git a/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts b/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts index fe6057fc28..58e70c5bfb 100644 --- a/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts +++ b/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts @@ -67,6 +67,8 @@ export class CleanRemoteNotesProcessorService { break; } + await this.notesRepository.delete(notes.map(note => note.id)); + for (const note of notes) { const t = this.idService.parse(note.id).date.getTime(); if (stats.oldest === null || t < stats.oldest) { @@ -77,8 +79,6 @@ export class CleanRemoteNotesProcessorService { } } - await this.notesRepository.delete(notes.map(note => note.id)); - cursor = notes.at(-1)?.id ?? null; stats.deletedCount += notes.length;