diff --git a/packages/content-fetch/src/redis_data_source.ts b/packages/content-fetch/src/redis_data_source.ts index b40c40677..1a95f9d6e 100644 --- a/packages/content-fetch/src/redis_data_source.ts +++ b/packages/content-fetch/src/redis_data_source.ts @@ -73,3 +73,16 @@ export const redisDataSource = new RedisDataSource({ REDIS_URL: process.env.REDIS_URL, REDIS_CERT: process.env.REDIS_CERT, }) + +// eslint-disable-next-line @typescript-eslint/no-misused-promises +process.on('SIGINT', async () => { + console.log('SIGINT signal received.') + + try { + await redisDataSource.shutdown() + } catch (error) { + console.error('error while shutting down redis', error) + } + + process.exit(0) +})