diff --git a/apps/worker/src/jobs/events.ts b/apps/worker/src/jobs/events.ts index 0313211b..44fa1f29 100644 --- a/apps/worker/src/jobs/events.ts +++ b/apps/worker/src/jobs/events.ts @@ -42,7 +42,7 @@ export async function eventsJob(job: Job) { async function updateEventsCount(projectId: string) { const res = await chQuery<{ count: number }>( - `SELECT * FROM events WHERE project_id = ${escape(projectId)}` + `SELECT count(*) as count FROM events WHERE project_id = ${escape(projectId)}` ); const count = res[0]?.count; if (count) {