Just reset everything each test run rather than trying to figure out …

…what is happening here.
PostHog · Nov 21, 2023 · 3061bd0 · 3061bd0
1 parent 185d834
commit 3061bd0
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 12 deletions.
diff --git a/plugin-server/src/worker/ingestion/app-metrics.ts b/plugin-server/src/worker/ingestion/app-metrics.ts
@@ -182,6 +182,8 @@ export class AppMetrics {
             } as RawAppMetric),
         }))
 
+        console.dir(this.kafkaProducer)
+
         await this.kafkaProducer.queueMessage({
             topic: KAFKA_APP_METRICS,
             messages: kafkaMessages,

diff --git a/plugin-server/tests/main/ingestion-queues/run-async-handlers-event-pipeline.test.ts b/plugin-server/tests/main/ingestion-queues/run-async-handlers-event-pipeline.test.ts
@@ -53,28 +53,21 @@ describe('runAppsOnEventPipeline()', () => {
     let redis: Redis.Redis
     let closeHub: () => Promise<void>
 
-    beforeEach(() => {
+    beforeEach(async () => {
         // Use fake timers to ensure that we don't need to wait on e.g. retry logic.
         jest.useFakeTimers({ advanceTimers: true })
-    })
-
-    beforeAll(async () => {
-        jest.useFakeTimers({ advanceTimers: true })
         ;[hub, closeHub] = await createHub()
         redis = await hub.redisPool.acquire()
         await hub.postgres.query(PostgresUse.COMMON_WRITE, POSTGRES_DELETE_TABLES_QUERY, null, 'deleteTables') // Need to clear the DB to avoid unique constraint violations on ids
     })
 
-    afterEach(() => {
-        jest.clearAllTimers()
-        jest.useRealTimers()
-        jest.restoreAllMocks()
-    })
-
-    afterAll(async () => {
+    afterEach(async () => {
         await hub.redisPool.release(redis)
         await teardownPlugins(hub)
         await closeHub()
+        jest.clearAllTimers()
+        jest.useRealTimers()
+        jest.restoreAllMocks()
     })
 
     test('throws on produce errors', async () => {