From a8bd3e8e53079685114e70d80e353f6fd8ceedf5 Mon Sep 17 00:00:00 2001
From: syuilo <Syuilotan@yahoo.co.jp>
Date: Wed, 15 Mar 2023 17:45:59 +0900
Subject: [PATCH] Update AggregateRetentionProcessorService.ts

---
 .../src/queue/processors/AggregateRetentionProcessorService.ts  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/packages/backend/src/queue/processors/AggregateRetentionProcessorService.ts b/packages/backend/src/queue/processors/AggregateRetentionProcessorService.ts
index fcfba75909..e2720b4fe0 100644
--- a/packages/backend/src/queue/processors/AggregateRetentionProcessorService.ts
+++ b/packages/backend/src/queue/processors/AggregateRetentionProcessorService.ts
@@ -63,7 +63,9 @@ export class AggregateRetentionProcessorService {
 			if (isDuplicateKeyValueError(err)) {
 				this.logger.succ('Skip because it has already been processed by another worker.');
 				done();
+				return;
 			}
+			throw err;
 		}
 
 		// 今日活動したユーザーを全て取得