disconnect producer

PostHog · Mar 20, 2024 · b22cdb8 · b22cdb8
1 parent 55c8ef5
commit b22cdb8
Showing 1 changed file with 2 additions and 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
@@ -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