zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: backfill sessions for imports

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2025-11-05 12:52:57 +01:00
parent b8cb13a854
commit 0663ce6ac8
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
packages/db/src/services/import.service.ts
View File

@@ -554,8 +554,20 @@ export async function backfillSessionsToProduction(
FROM ${TABLE_NAMES.events_imports} e FROM ${TABLE_NAMES.events_imports} e
WHERE WHERE
e.import_id = ${sqlstring.escape(importId)} e.import_id = ${sqlstring.escape(importId)}
AND toDate(e.created_at) = ${sqlstring.escape(from)}
AND e.session_id != '' AND e.session_id != ''
AND (
(toDate(e.created_at) = ${sqlstring.escape(from)}) OR
(
e.name IN ('session_start', 'session_end') AND
e.session_id IN (
SELECT DISTINCT session_id
FROM ${TABLE_NAMES.events_imports}
WHERE import_id = ${sqlstring.escape(importId)}
AND toDate(created_at) = ${sqlstring.escape(from)}
AND name NOT IN ('session_start', 'session_end')
)
)
)
GROUP BY e.session_id GROUP BY e.session_id
`; `;
@@ -669,6 +681,7 @@ export async function getImportDateBounds(
SELECT min(created_at) AS min, max(created_at) AS max SELECT min(created_at) AS min, max(created_at) AS max
FROM ${TABLE_NAMES.events_imports} FROM ${TABLE_NAMES.events_imports}
WHERE import_id = {importId:String} WHERE import_id = {importId:String}
AND name NOT IN ('session_start', 'session_end')
${fromCreatedAt ? 'AND created_at >= {fromCreatedAt:String}' : ''} ${fromCreatedAt ? 'AND created_at >= {fromCreatedAt:String}' : ''}
`, `,
query_params: { importId, fromCreatedAt }, query_params: { importId, fromCreatedAt },