diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2023-03-15 17:45:59 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2023-03-15 17:45:59 +0900 |
| commit | a8bd3e8e53079685114e70d80e353f6fd8ceedf5 (patch) | |
| tree | d3e7285e2510ccbf50e3b54c3eb750a1ebf3e192 /packages/backend/src/queue | |
| parent | fix: tweak retention rate aggregation (diff) | |
| download | sharkey-a8bd3e8e53079685114e70d80e353f6fd8ceedf5.tar.gz sharkey-a8bd3e8e53079685114e70d80e353f6fd8ceedf5.tar.bz2 sharkey-a8bd3e8e53079685114e70d80e353f6fd8ceedf5.zip | |
Update AggregateRetentionProcessorService.ts
Diffstat (limited to 'packages/backend/src/queue')
| -rw-r--r-- | packages/backend/src/queue/processors/AggregateRetentionProcessorService.ts | 2 |
1 files changed, 2 insertions, 0 deletions
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; } // 今日活動したユーザーを全て取得 |