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,