From b22cdb888358f8d4f31fcf80f0afa5e4b3b50121 Mon Sep 17 00:00:00 2001
From: Paul D'Ambra <paul@posthog.com>
Date: Wed, 20 Mar 2024 12:48:37 +0000
Subject: [PATCH] disconnect producer

---
 .../session-recording/session-recordings-consumer.ts           | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugin-server/src/main/ingestion-queues/session-recording/session-recordings-consumer.ts b/plugin-server/src/main/ingestion-queues/session-recording/session-recordings-consumer.ts
index cb98e4353381a..c0bf69703dce8 100644
--- a/plugin-server/src/main/ingestion-queues/session-recording/session-recordings-consumer.ts
+++ b/plugin-server/src/main/ingestion-queues/session-recording/session-recordings-consumer.ts
@@ -230,7 +230,6 @@ export class SessionRecordingIngester {
          */
         this.promises.add(promise)
 
-        // eslint-disable-next-line @typescript-eslint/no-floating-promises
         promise.finally(() => this.promises.delete(promise))
 
         return promise
@@ -545,6 +544,8 @@ export class SessionRecordingIngester {
         await this.redisPool.drain()
         await this.redisPool.clear()
 
+        await this.ingestionWarningProducer?.disconnect()
+
         status.info('👍', 'blob_ingester_consumer - stopped!')
 
         return promiseResults