From 88440c46f3d83dbc13416bfe56802f40ab178b07 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= Date: Mon, 23 Sep 2024 20:00:40 +0200 Subject: [PATCH] fix(worker): try improve speed --- apps/worker/src/jobs/events.create-session-end.ts | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/apps/worker/src/jobs/events.create-session-end.ts b/apps/worker/src/jobs/events.create-session-end.ts index 57f0f420..7b187593 100644 --- a/apps/worker/src/jobs/events.create-session-end.ts +++ b/apps/worker/src/jobs/events.create-session-end.ts @@ -3,6 +3,8 @@ import { last } from 'ramda'; import { getTime } from '@openpanel/common'; import { + IClickhouseEvent, + type IServiceEvent, TABLE_NAMES, createEvent, eventBuffer, @@ -43,9 +45,10 @@ export async function createSessionEnd( }); const payload = job.data.payload; - const eventsInBuffer = await eventBuffer.findMany( - (item) => item.session_id === payload.sessionId, - ); + const eventsInBuffer: IServiceEvent[] = []; + // const eventsInBuffer = await eventBuffer.findMany( + // (item) => item.session_id === payload.sessionId, + // ); let eventsInDb = await getCompleteSession({ projectId: payload.projectId,