Add base macro functionality

snowplow · Aug 31, 2023 · 11234ee · 11234ee
1 parent 9877aea
commit 11234ee
Show file tree

Hide file tree

Showing 138 changed files with 4,929 additions and 303 deletions.
diff --git a/LICENSE b/LICENSE
diff --git a/integration_tests/.scripts/integration_tests.sh b/integration_tests/.scripts/integration_tests.sh
@@ -37,6 +37,22 @@ for db in ${DATABASES[@]}; do
 
   eval "dbt test --exclude tag:requires_script --target $db --store-failures" || exit 1;
 
+  echo "Snowplow-utils native dbt tests: Run custom base macro models"
+
+  eval "dbt run --select tag:base_macro --target $db --full-refresh --vars 'snowplow__custom_test: true'" || exit 1;
+
+  echo "Snowplow-utils native dbt tests: Test custom base macro models"
+
+  eval "dbt test --select tag:base_macro --target $db --vars 'snowplow__custom_test: true' --store-failures" || exit 1;
+
+  echo "Snowplow-utils native dbt tests: Run custom session sql base macro models"
+
+  eval "dbt run --select tag:base_macro --target $db --full-refresh --vars 'snowplow__session_test: true'" || exit 1;
+
+  echo "Snowplow-utils native dbt tests: Test custom base macro models"
+
+  eval "dbt test --select tag:base_macro --exclude snowplow_base_quarantined_sessions_actual --target $db --vars 'snowplow__session_test: true' --store-failures" || exit 1;
+
   echo "Snowplow utils integration tests: Run script based tests"
 
   echo "Snowplow-utils integration tests: Testing get_successful_models"

diff --git a/integration_tests/.scripts/test_get_enabled_snowplow_models.sh b/integration_tests/.scripts/test_get_enabled_snowplow_models.sh
@@ -12,7 +12,7 @@ done
 
 echo "Test get_enabled_snowplow_models: Untagged model"
 
-OUTPUT=$(eval "dbt test --models test_get_enabled_snowplow_models --target $DATABASE --vars \"{'tag_var': 'random_tag'}\"")
+OUTPUT=$(eval "dbt test --select test_get_enabled_snowplow_models --target $DATABASE --vars \"{'tag_var': 'random_tag'}\"")
 EXIT_CODE=$?
 
 if [[ $OUTPUT == *"Snowplow Warning: Untagged models referencing"* ]]; then
@@ -28,13 +28,11 @@ fi
 
 echo "Test get_enabled_snowplow_models: All models"
 
-eval "dbt test --models test_get_enabled_snowplow_models --target $DATABASE" || exit 1;
+eval "dbt test --select test_get_enabled_snowplow_models --target $DATABASE" || exit 1;
 
 echo "Test get_enabled_snowplow_models: Subset of models"
 
 # TODO: Use the dbt ls command instead of hardcoding. Issue is the model has to exist in the project. Models may well change in the int test dir.
-eval "dbt test --models test_get_enabled_snowplow_models --target $DATABASE --vars \"{'models_to_run': 'enabled_model_w_dependency non_snowplow_model'}\"" || exit 1;
+eval "dbt test --select test_get_enabled_snowplow_models --target $DATABASE --vars \"{'models_to_run': 'enabled_model_w_dependency non_snowplow_model test'}\"" || exit 1;
 
 echo "Test get_enabled_snowplow_models: All tests passed"
-
-
diff --git a/integration_tests/data/base/expected/snowplow_base_events_this_run_expected.csv b/integration_tests/data/base/expected/snowplow_base_events_this_run_expected.csv
diff --git a/integration_tests/data/base/expected/snowplow_base_events_this_run_expected_custom.csv b/integration_tests/data/base/expected/snowplow_base_events_this_run_expected_custom.csv
diff --git a/...ation_tests/data/base/expected/snowplow_base_events_this_run_expected_sessions_custom.csv b/...ation_tests/data/base/expected/snowplow_base_events_this_run_expected_sessions_custom.csv
diff --git a/integration_tests/data/base/expected/snowplow_base_quarantined_sessions_expected.csv b/integration_tests/data/base/expected/snowplow_base_quarantined_sessions_expected.csv
@@ -0,0 +1,2 @@
+session_identifier
+2bfc2c760c3ac434953eefd7903789429c8a5f8171c4b8b26aee93108b77bd35
diff --git a/integration_tests/data/base/expected/snowplow_base_quarantined_sessions_expected_custom.csv b/integration_tests/data/base/expected/snowplow_base_quarantined_sessions_expected_custom.csv
@@ -0,0 +1,2 @@
+session_identifier
+887766f6-dc02-4eb1-9ec5-c997f1cd0d3b
diff --git a/..._tests/data/base/expected/snowplow_base_quarantined_sessions_expected_sessions_custom.csv b/..._tests/data/base/expected/snowplow_base_quarantined_sessions_expected_sessions_custom.csv
@@ -0,0 +1 @@
+session_identifier
diff --git a/integration_tests/data/base/expected/snowplow_base_sessions_this_run_expected.csv b/integration_tests/data/base/expected/snowplow_base_sessions_this_run_expected.csv
@@ -0,0 +1,46 @@
+session_identifier,user_identifier,start_tstamp,end_tstamp
+df2bf41d09f5f900cd6bd564d1ae403843c9cd767081e38bf614c950a4f73b32,066d5a7eecd5792fc6700998b72e58da69e690d9a6fb23c3b70f2bdb41230a70,2021-03-02 07:23:18.542,2021-03-02 07:23:23.357
+6f19f1f4f43224f646d6fed6358c39152faa088f7ab2d90f0a791ea1210a4656,066d5a7eecd5792fc6700998b72e58da69e690d9a6fb23c3b70f2bdb41230a70,2021-03-02 07:23:18.542,2021-03-02 07:23:27.085
+0b0c7bb589ebd041177514f3e43446ca5d4343328936d2f8f12a42b41bf9140d,0691aaf040cd39a08408e62e5d015cc2cef433f1a95e5f6767d62d24bd4be237,2021-03-02 22:59:29.753,2021-03-02 22:59:29.753
+0b0c7bb589ebd041177514f3e43446ca5d4343328936d2f8f12a42b41bf9140c,0691aaf040cd39a08408e62e5d015cc2cef433f1a95e5f6767d62d24bd4be237,2021-03-02 15:55:18.542,2021-03-02 15:59:29.753
+93c11143f1de24d8f77c80bd138e815aa705a32a288a2b71bee522426b9aacc8,24837eb265f7e3f2e82196a3c3a05bf028135683819ab8ded7b8b79753bd52dd,2021-03-02 02:01:27.085,2021-03-02 02:01:27.085
+cde5b90f34224b1a94351fa90fcb61d41b26a52a1a8381603cf538a11edd2bb2,24837eb265f7e3f2e82196a3c3a05bf028135683819ab8ded7b8b79753bd52dd,2021-03-02 02:01:18.542,2021-03-02 02:01:27.085
+37b340c11359852988ae9b4f77f0c4b283cf2d4e87e2b5e5bceda36a185b81ff,434dff58299fdc4f124ddf56a4f117d76f69bedb06f76d9858ffde85e16e14e1,2021-03-02 23:57:04.708,2021-03-03 00:47:49.411
+7605342329f0b916a4c1bcd8bddad038988920fb24f74ca9e7ada5d96df32c60,f897c486aa47cefa7478e3db62c797922b9fe006fc10fc05dd4b71abbbbdcae2,2021-03-02 19:25:22.757,2021-03-02 20:08:24.466
+540b6c4f7c15de9093e0f4f6cf45a062fba7606ce64558a0b1c5a34d8bb33af5,2e340eb6e94820ea8369c0174c612260d1cfe9d41f0fe46268994e28d9c0bbf17,2021-03-02 15:55:18.542,2021-03-04 15:55:27.085
+79831faefff0edc56d0d93ccf192b5bb58c07bec8dfff185f5cc4b104c2f0a08,434dff58299fdc4f124ddf56a4f117d76f69bedb06f76d9858ffde85e16e14e1,2021-03-01 23:57:04.708,2021-03-01 23:57:07.557
+4d34b56a2a474e7c5d7f125c9a0ed11b7e526bf99910d6d31afaf6a8cc25d7ae,b3c883845957060b8cbebdaec8366d1d4ec6ad283eba1c70e8a512ec43d10875,2021-03-01 18:01:08.690,2021-03-01 18:01:11.026
+b5c4939c16dd0f5a4396ca24474d8b050786710b1b48319ba19c5febfcb71a3b,,2021-03-01 17:09:42.324,2021-03-01 17:09:42.324
+2bfc2c760c3ac434953eefd7903789429c8a5f8171c4b8b26aee93108b77bd35,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-01 21:39:43.815,2021-03-04 21:39:43.815
+e7971181261e72dbc9abe9eb6cdfe9eb7ae86085b2e9b39b7ed1fae2404b74e8,ff7476176c5d1d89c760645b851c595096bab40f6f4a35752f96360dd534a0bb,2021-03-01 00:30:19.971,2021-03-01 00:30:20.182
+067bcc8ea082fcaf940893b64943edc6b718f0dd1bc1bd5d054a507c64048318,bc0da66ea89bbb0991f1c37ecdc1830a97f1ed9e24296ef6dbf19635220a064e,2021-03-01 20:45:42.175,2021-03-01 20:59:20.601
+76866d07c098a96aba7a9c0efe830a68a1027d1268fbfe508279fdcb7fff258e,1de9fb9888e07e9991c52fb120a7be51309716bac09889e6bd5a09322cd301eb,2021-02-26 09:13:21.563,2021-02-26 09:13:30.423
+3a580aee269b69177d7306ef1e1d4e0acdc846c379449b71861b8f3918c4c6be,07fde81e45ba6f5592a8fff724af99e4df5041945fc576f5daf9cbfdbf1a270e,2021-02-26 09:09:31.304,2021-02-26 09:09:31.304
+3e691dfad8c64723e4b7e69c2e5f8ad04a0a8f5909e8cc7f427f7d8e98d412cb,da03a5870047e2c5a11c07f101695745a9e5adac316d1193cb55aa2c6485f611,2021-02-26 09:13:11.723,2021-02-26 09:13:13.220
+83f26b23d2cda96cd343f0127872483476e1ceabad8405354f2cf9b016dd0c36,134db4187db0e51bc13ad9f2f5e839edc04450757f6aa6cababd64f85056a805,2021-02-26 09:12:30.142,2021-02-26 09:12:54.174
+90af0c6f7463fc73b62d806cd8766617eec590e5da9eda06e93145a0bd210ad7,2816bdb9d221b9354c1d45472e3624b7531265c5d644bb2aa760c1b6b57a3d8e,2021-02-26 09:11:49.893,2021-02-26 09:11:53.055
+7ccbd6f19df7148f2465c8b49a4393183a0b0686551f816bb8d6f927cbd1456e,7e3708bb1215322c1c027e4221f2d9827efac748a8cc86c31af0b9189497d8f1,2021-02-26 09:09:03.413,2021-02-26 09:09:04.213
+f2548eca4408f598564cf8eb538e500958e6d37fcf8a31fc67e65d0dc106ccfd,e68aed5607b154baa57412f64e5111ca75ae44366e31e25bc12cb55126fb3927,2021-02-26 09:10:32.282,2021-02-26 09:10:42.881
+d4ff9239df44c0118230604421cbce045d151003eeb9e2d6c2ea636d4f76b902,4b0897e90a332f443964f2549dfee262f1f673a5ccacf2bd21d17c0bec50c572,2021-02-26 09:12:22.256,2021-02-26 09:12:23.161
+9b36ac17669e3daa5e6a3fbbdad2aa1fb1a955890009729cf50a4d08a60f21b7,8b996f0b240407b9c815f217e172be56c2f8b2d92edaddfaf03c293197ec00c4,2021-02-26 09:10:59.572,2021-02-26 09:11:09.446
+c108fe1f4b9e3dc6bdee09b113757168376a21dcd9baa3fe44addcf81e43ca5e,1c2e3fabb7cc1c6c1ba7789c1821ccb32e24cb064074c514f05a99bce4590a9f,2021-02-26 09:09:13.509,2021-02-26 09:09:14.705
+99f714c328e2199b47b3adfa64256b094d372e1b7373bb3f38ab26da22b04a2c,f75a85d70c476daad5346389a17cb7611bcad04ac23dc7793c2da5a28d3fc4b3,2021-02-26 09:09:52.031,2021-02-26 09:09:54.064
+903567378ac414a23177416bee078ef09fe022ea4de57d2319c2d19b88c72b92,a3126628f62daa41fa82c51e6eb2430645a1c000356e2dde3237310b7da28c06,2021-02-26 09:13:49.634,2021-02-26 09:13:51.444
+6b6879d9e53e997aa9088804875db367278932be0dc35363d4e53113919a631e,6ca9c8b725d2e3c76cd49fb6f4fe1fcc47684380876e99dc18dc0861a5d7f58e,2021-02-26 09:12:13.298,2021-02-26 09:12:15.804
+166b0f10fed15ab16fa0af92e3ec6553d405b9de6f6e1c2c5c647e7b454fbb80,ada2a4d74ae4a10bcba4440a1a9f35207d0b6a33303e024c3efe07b76620070b,2021-02-26 09:11:16.598,2021-02-26 09:11:30.207
+5218442a0d964fb71046c481e1a339d55571c8550efa366291a81dc59e685b3d,7a1f9fdd5eba61e0c6b848879bdc46e270341a5dbf3509e5663f0c841135bc95,2021-02-26 09:10:49.990,2021-02-26 09:10:52.577
+5e08b7d4c11cd89a37cc3d17b8805ba799607c59768c367e81588dc22a2d4635,319f2800aa7cb1792187806d0c37e20a644b891c31da473979e057e7e8619506,2021-02-26 09:08:53.689,2021-02-26 09:08:54.814
+1199fe617dcd77586c64415afb4e9339b7b9dc09de006eb1bf1d2c043262888a,55572b5893a5fd343df9d1d90c5a33de6baaa268018b9ab3f851a509414bc3cc,2021-02-26 09:11:39.201,2021-02-26 09:11:41.195
+bfdf84360c57f3a6717aeef737eb5acc4a52be052bb535ce65d776ce1e052329,e2cd5ee3d241a43551ca5cba411cd1a45b42212d327f23cfaa26fe3309230af6,2021-02-26 09:10:10.249,2021-02-26 09:10:12.530
+50c7ec69e5e45dbfaa34d0d4cf95804025b3afb4486cf23d615106105614c1c2,4e28e51765e9c3fc3b5b7090a47a0a04ea204d0b6d1070e6844607faf95badfd,2021-02-26 09:10:00.913,2021-02-26 09:10:03.418
+98e03561d7f6ae6b427ed9febfa5f629f536f4592a1aa60221fc4cad30c1b6b0,14adabe838147abf8a9ded33827f7e0b109221d7e0f7aad87166010ee9e1ebc9,2021-02-26 09:13:39.082,2021-02-26 09:13:39.940
+94dd018c59f7402ae0c5bc1d0580f67ce8fc8a6d40007b202e15310db093ec3e,500f51265e0bf069bec25770e498c9d54fa89a1eed44d4a08d999d5e2f7852ab,2021-02-26 09:09:40.737,2021-02-26 09:09:42.497
+dc662c1a53d38f910d380bdb2d0cca3fcd55a15752a581d874571bfb2479e644,5a5b329daba8f027ed85c30dd00f0ae5f5ac4c4b53cd26a7816b88e10158b97a,2021-02-26 09:08:28.324,2021-02-26 09:08:46.917
+6cc9e83a85c5d8f6a081f933d77bc1ca801c6166a07a65a06e8189467a4766fe,f16ba0227d205b0269501cfb4cfd9f010fc4069c2901e530a9bdffcf21ff7242,2021-02-26 09:09:22.656,2021-02-26 09:09:24.713
+869261383bb07eb621b0b231d6c2e74757179fd40dcfc0bcecbc72dc4613317b,00806d345ef7311fafe3ea0b9967e515016d9c8b76e4803e714346e38b9d88bd,2021-02-26 09:13:01.552,2021-02-26 09:13:04.615
+ed61377bf8dfa0a6e258ee1342067f1df9d3df24fc90180a3e0f5fcdecaa0dc9,0f71eec8632b70a49da4c51f0397b06bfd3809cec5b19988cd6c31eb73448993,2021-02-26 09:12:02.380,2021-02-26 09:12:05.520
+e45e0ee9f7a7cae60065a4c29dd5d80f37f2dbbf462c2335456b30336301ee42,5c33a6ad2bfdd4e3834eaa82587236422263213cb7c3a72c133c8c7546282d36,2021-03-03 09:14:00.224,2021-03-03 09:14:01.599
+0b5d421a98dc6af66d7da30840afb1072f518342ca058cef3af20a6e9b30fce8,b3c883845957060b8cbebdaec8366d1d4ec6ad283eba1c70e8a512ec43d10875,2021-03-03 18:01:38.660,2021-03-03 18:01:38.660
+6b379f3eea11eb4ead878125af9cb708f8a91c455d9405b0bc617fa78c2e4291,5d27ff97148de9e5f1c23e8fd0a4382c06852969f6495def03c66599e676f449,2021-03-03 21:27:23.097,2021-03-03 21:27:35.706
+0b0c7bb589ebd041177514f3e43446ca5d4343328936d2f8f12a42b41bf9140e,0691aaf040cd39a08408e62e5d015cc2cef433f1a95e5f6767d62d24bd4be237,2021-03-04 22:59:29.753,2021-03-04 22:59:29.753
+d21c000a5953335da6cd125ac349135ae6524b04dd4b107a263dfb1de131b12d,12c98e1f5869e3f298fef62699ad9bbe5410d1685e8344a1a1f86e92029685f0,2021-03-04 15:55:27.085,2021-03-04 15:55:27.085
diff --git a/integration_tests/data/base/expected/snowplow_base_sessions_this_run_expected_custom.csv b/integration_tests/data/base/expected/snowplow_base_sessions_this_run_expected_custom.csv
@@ -0,0 +1,46 @@
+session_identifier,user_identifier,start_tstamp,end_tstamp
+5a82c657-0de5-4387-a2ac-cd940e22d614,0303c73c-928a-4836-b14e-af4828a1c121,2021-03-02 07:23:18.542,2021-03-02 07:23:23.357
+082c22fa-af0a-437a-a1f2-290138f23772,0303c73c-928a-4836-b14e-af4828a1c121,2021-03-02 07:23:18.542,2021-03-02 07:23:27.085
+bc6edaee-67d7-473b-a04a-bfa13de6bf85,559ffc47-4fa2-4279-a5cc-7f3e8747c10b,2021-03-02 22:59:29.753,2021-03-02 22:59:29.753
+26633187-3bd8-4f1c-b206-35082aaf5e1a,559ffc47-4fa2-4279-a5cc-7f3e8747c10b,2021-03-02 15:55:18.542,2021-03-02 15:59:29.753
+56ad1cbd-d20f-461f-a8a9-4ff7788e6723,a4102b0e-5ded-49b0-859b-20b64e561657,2021-03-02 02:01:27.085,2021-03-02 02:01:27.085
+7acfa045-8e47-4397-92f8-f57e12a76c14,a4102b0e-5ded-49b0-859b-20b64e561657,2021-03-02 02:01:18.542,2021-03-02 02:01:27.085
+cfde71e2-fb60-4c44-94ae-5471389b7495,7ce341e7-fd4c-44ed-8c2b-f420a0326098,2021-03-02 23:57:04.708,2021-03-03 00:47:49.411
+dc1c41b2-f41c-4f1c-b532-8a7aad66b0d8,0569580b-0eeb-4789-93df-c27e5b68528c,2021-03-02 19:25:22.757,2021-03-02 20:08:24.466
+c02647fc-0948-43d3-965d-b9e737a133e1,f0d86bd7-dc66-4dd3-af68-c4a1ea7a349d,2021-03-02 15:55:18.542,2021-03-04 15:55:27.085
+86569d01-2e5c-4143-aa5a-a992c89a317b,7ce341e7-fd4c-44ed-8c2b-f420a0326098,2021-03-01 23:57:04.708,2021-03-01 23:57:07.557
+a68dc645-e632-4270-8310-b66ef7832701,30f86c8f-0617-4d43-a1ed-f98704ae7f44,2021-03-01 18:01:08.690,2021-03-01 18:01:11.026
+926d432a-1329-4eba-b02b-b9067cde388b,,2021-03-01 17:09:42.324,2021-03-01 17:09:42.324
+887766f6-dc02-4eb1-9ec5-c997f1cd0d3b,eba1dbc1-4847-4099-96b0-8966a9294f88,2021-03-01 21:39:43.815,2021-03-04 21:39:43.815
+aea7c9a8-d259-47ea-9310-3467d44b0642,e61a75a5-f96a-4ea0-9808-cd2903f87171,2021-03-01 00:30:19.971,2021-03-01 00:30:20.182
+6303c3ff-5c97-499e-91ce-011e9f8f13a7,f5191cc0-63a0-4070-adb6-af5722dd8155,2021-03-01 20:45:42.175,2021-03-01 20:59:20.601
+a7ab156a-1ab3-4baa-b718-93de9d9f8174,ddce1591-1eba-4371-80be-76190625415e,2021-02-26 09:13:21.563,2021-02-26 09:13:30.423
+6251bc4f-3df4-410e-af4d-aac89d191521,6a73be7e-1c95-411a-9432-52fc3abc41c6,2021-02-26 09:09:31.304,2021-02-26 09:09:31.304
+459589db-02c2-4df6-b1cc-3c0ebc54311a,24d2b835-e185-4987-9433-140592360732,2021-02-26 09:13:11.723,2021-02-26 09:13:13.220
+d5c23706-4174-4aa1-9234-0e4c87897107,3ba33c65-7ebb-477f-bce5-32efc9555765,2021-02-26 09:12:30.142,2021-02-26 09:12:54.174
+a43d844f-20c6-4d3d-8647-d10064dca290,c2c42614-19d5-4034-83b8-ea8aade5c543,2021-02-26 09:11:49.893,2021-02-26 09:11:53.055
+f417f5b0-c2b2-412e-a7d1-ffac5ebe417f,32ac9914-8acf-4d1f-892f-781b508c3f39,2021-02-26 09:09:03.413,2021-02-26 09:09:04.213
+8533a718-21f4-4d38-bf72-45f98d936784,7cdcba52-d9f7-460c-bdb2-f627838e718d,2021-02-26 09:10:32.282,2021-02-26 09:10:42.881
+80747f66-96d5-4929-b9ab-723666ce4ee6,43026689-d403-47af-a248-894ef8f0165e,2021-02-26 09:12:22.256,2021-02-26 09:12:23.161
+80f425c6-0080-4b00-8f7e-4d42b2f97e57,113a4405-4810-44b4-a41b-ebc5401afcc6,2021-02-26 09:10:59.572,2021-02-26 09:11:09.446
+cc8f6a95-5c0e-4d8a-a667-e819857450da,3db900f6-01e5-40be-9f3e-eae9c4f2d5de,2021-02-26 09:09:13.509,2021-02-26 09:09:14.705
+1f783711-26a8-47f5-a878-d1239f04fb94,baaa3b74-f0fc-4f22-a462-969fec6b790e,2021-02-26 09:09:52.031,2021-02-26 09:09:54.064
+7978ec05-7187-4c64-805f-3504d71df86b,0d1609f3-559b-44dd-acc2-fd43856ea652,2021-02-26 09:13:49.634,2021-02-26 09:13:51.444
+76c4f7d6-e93f-4ce5-8484-929f4e5beb69,ce328157-43d7-40d5-a1fd-79c4e7fd9fa5,2021-02-26 09:12:13.298,2021-02-26 09:12:15.804
+f16ec375-0925-4a71-b0e3-1887e6937924,b6090908-384d-4bdc-adc7-7e686a9e23c5,2021-02-26 09:11:16.598,2021-02-26 09:11:30.207
+15ee7e41-4a64-4920-af29-9c7343027c19,2c6c26e8-138d-404b-9f7c-1669e4d9737a,2021-02-26 09:10:49.990,2021-02-26 09:10:52.577
+152fb419-7f38-4d39-8817-5c3db7e15fad,fc1eace4-1d52-49cc-886b-3557df1763e0,2021-02-26 09:08:53.689,2021-02-26 09:08:54.814
+7bfedd57-f9c9-49f5-8274-3790a7e03e9e,ee27b581-73d5-49f8-9092-3734d9cf8628,2021-02-26 09:11:39.201,2021-02-26 09:11:41.195
+fd3dd30e-5fef-4139-9059-6354a513fba2,74082219-e83a-4be5-a14a-221f71233b76,2021-02-26 09:10:10.249,2021-02-26 09:10:12.530
+eb7e8b36-d084-4dae-8eb3-c4570bf4d972,63f4b6e7-268b-4a32-81ca-a94bcbe5e3a4,2021-02-26 09:10:00.913,2021-02-26 09:10:03.418
+44bf9924-f888-4827-86fe-aacfee2fbdfe,16a0ad6b-2a8a-4235-a437-3d1dbe799ecf,2021-02-26 09:13:39.082,2021-02-26 09:13:39.940
+bc48d21d-38f7-46a1-abda-2068fe112d34,62e45c60-a025-4408-9767-a7909db4bb4a,2021-02-26 09:09:40.737,2021-02-26 09:09:42.497
+e7e08986-3443-4487-870d-a0eae2bbe506,63ed4702-75df-4990-bc69-a87872f146ef,2021-02-26 09:08:28.324,2021-02-26 09:08:46.917
+6099094d-3f54-4fe0-95ec-d14cd2b7e2ea,361d219f-535c-48a1-bdc4-e6c50fc97193,2021-02-26 09:09:22.656,2021-02-26 09:09:24.713
+7d029b42-911e-4164-84a1-abd7bb72aa86,419c7698-418e-45c1-b1ba-e5d93f72cd99,2021-02-26 09:13:01.552,2021-02-26 09:13:04.615
+4535331d-34f9-453c-a47a-1be0137e2432,738fab00-c924-45d2-8999-3c5135129852,2021-02-26 09:12:02.380,2021-02-26 09:12:05.520
+f8e7c6a3-ee27-4794-8fd1-4877e0323d4a,86053399-b837-4875-8161-fc9eb7e7956b,2021-03-03 09:14:00.224,2021-03-03 09:14:01.599
+9437c522-8292-4824-a740-7c091335ed03,30f86c8f-0617-4d43-a1ed-f98704ae7f44,2021-03-03 18:01:38.660,2021-03-03 18:01:38.660
+eeab8db4-b947-47d6-834d-2f0e4a87e99c,a325429f-b93a-4ff2-9091-10b9cbad135e,2021-03-03 21:27:23.097,2021-03-03 21:27:35.706
+c3c90086-adc8-4df0-ad56-66e16202026a,559ffc47-4fa2-4279-a5cc-7f3e8747c10b,2021-03-04 22:59:29.753,2021-03-04 22:59:29.753
+a4efcbe7-6efb-4fd3-91c6-895fa4d1bb01,ffb855ff-6a23-405a-8846-6609e484061d,2021-03-04 15:55:27.085,2021-03-04 15:55:27.085
diff --git a/...ion_tests/data/base/expected/snowplow_base_sessions_this_run_expected_sessions_custom.csv b/...ion_tests/data/base/expected/snowplow_base_sessions_this_run_expected_sessions_custom.csv
@@ -0,0 +1,12 @@
+session_identifier,user_identifier,start_tstamp,end_tstamp
+2021-02-26,f75a85d70c476daad5346389a17cb7611bcad04ac23dc7793c2da5a28d3fc4b3,2021-02-26 09:08:28.324000,2021-02-26 09:13:51.444000
+2021-03-01,ff7476176c5d1d89c760645b851c595096bab40f6f4a35752f96360dd534a0bb,2021-03-01 00:30:19.971000,2021-03-01 23:57:07.557000
+2021-03-02,f897c486aa47cefa7478e3db62c797922b9fe006fc10fc05dd4b71abbbbdcae2,2021-03-02 02:01:18.542000,2021-03-02 23:57:07.557000
+2021-03-03,b3c883845957060b8cbebdaec8366d1d4ec6ad283eba1c70e8a512ec43d10875,2021-03-03 00:17:16.091000,2021-03-03 21:39:50.989000
+2021-03-04,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-04 15:55:27.085000,2021-03-04 22:59:29.753000
+2021-03-05,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-05 21:39:51.022000,2021-03-05 21:39:51.022000
+2021-03-06,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-06 21:40:46.189000,2021-03-06 21:40:46.189000
+2021-03-07,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-07 21:40:46.189000,2021-03-07 21:40:46.189000
+2021-03-08,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-08 21:40:46.240000,2021-03-08 21:40:46.240000
+2021-03-09,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-09 21:41:56.571000,2021-03-09 21:41:56.571000
+2021-03-10,4f011c929234934761dfff0bca3b5509a1b6d139560439e894a8d26a363654ad,2021-03-10 21:41:56.625000,2021-03-10 21:41:56.625000
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		session_identifier
		2bfc2c760c3ac434953eefd7903789429c8a5f8171c4b8b26aee93108b77bd35
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		session_identifier
		887766f6-dc02-4eb1-9ec5-c997f1cd0d3b