Update AggregateRetentionProcessorService.ts

2023-03-15 17:45:59 +09:00 · 2023-03-15 17:45:59 +09:00 · a8bd3e8e53
parent 58fc17e3b6
commit a8bd3e8e53
1 changed files with 2 additions and 0 deletions
--- 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;
 		}

 		// 今日活動したユーザーを全て取得