Skip to content
This repository was archived by the owner on Jun 13, 2025. It is now read-only.

Commit d803204

Browse files
author
DanLee
authored
Merge pull request #11 from dataform-co/dataform_fix_screen_event_name
A few bug fixes
2 parents 48067fa + ac38499 commit d803204

3 files changed

Lines changed: 8 additions & 6 deletions

File tree

definitions/example.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,9 @@ const segmentModels = segment({
1010
},
1111
customPageFields: ["url_hash", "category"],
1212
customUserFields: ["email", "name", "company_name", "created_at"],
13-
includeScreens: false
13+
includeScreens: false,
14+
includePages: true,
15+
includeTracks: true
1416
});
1517

1618
declare({

includes/common.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ let TRACK_FIELDS = {
2222

2323
// From here: https://segment.com/docs/connections/spec/screen/
2424
let SCREEN_FIELDS = {
25-
event: "name"
25+
name: "name"
2626
};
2727

2828
function allPageFields(params) {

includes/sessions.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,11 +85,11 @@ select
8585
${segmentCommon.enabledEvents(params).map((event) =>
8686
`count(segment_sessionized_events.${event}_id) as total_${event}s`).join(`,\n `)},
8787
${crossdb.timestampDiff("millisecond", "min(segment_sessionized_events.timestamp)", "max(segment_sessionized_events.timestamp)")} as duration_millis
88-
${ctx.when(global.session.config.warehouse == "bigquery", `) as stats`)},
88+
${ctx.when(global.session.config.warehouse == "bigquery", `) as stats`)}
8989
9090
-- first values in the session for page fields
91-
${params.includePages ?
92-
`${ctx.when(global.session.config.warehouse == "bigquery", `struct(\n `)}
91+
${params.includePages ?
92+
`, ${ctx.when(global.session.config.warehouse == "bigquery", `struct(\n `)}
9393
${Object.entries(segmentCommon.allPageFields(params)).map(
9494
([key, value]) => `first_and_last_page_values.first_${value}`).join(",\n ")}
9595
${ctx.when(global.session.config.warehouse == "bigquery", `) as first_page_values`)},
@@ -101,7 +101,7 @@ select
101101
102102
-- first values in the session for screen fields
103103
${params.includeScreens ?
104-
`${ctx.when(global.session.config.warehouse == "bigquery", `struct(\n `)}
104+
`, ${ctx.when(global.session.config.warehouse == "bigquery", `struct(\n `)}
105105
${Object.entries(segmentCommon.allScreenFields(params)).map(
106106
([key, value]) => `first_and_last_screen_values.first_${value}`).join(",\n ")}
107107
${ctx.when(global.session.config.warehouse == "bigquery", `) as first_screen_values`)},

0 commit comments

Comments
 (0)