()
| 90 | } |
| 91 | |
| 92 | private async clearOldEventsSafely(): Promise<void> { |
| 93 | try { |
| 94 | await Promise.race([ |
| 95 | this.maintenanceService.clearOldEvents(), |
| 96 | delayMs(CLEAR_OLD_EVENTS_TIMEOUT_MS).then(() => { |
| 97 | throw new Error(`clearOldEvents timed out after ${CLEAR_OLD_EVENTS_TIMEOUT_MS}ms`) |
| 98 | }), |
| 99 | ]) |
| 100 | } catch (error) { |
| 101 | logger('unable to clear old events: %o', error) |
| 102 | } |
| 103 | } |
| 104 | |
| 105 | public run(): void { |
| 106 | this.interval = setInterval(async () => { |
no test coverage detected