feat(pipelines/cdp): finalize customer data platform with sessionization and customer 360 profiles - #274

Merged

iht merged 9 commits into

GoogleCloudPlatform:mainfrom

iht:feat/cdp-sessionization-pipeline

Sep 8, 2026

Commits on Sep 7, 2026

feat(pipelines/cdp): finalize customer data platform with sessionization and customer 360 profiles
iht
committed
9fd7e50
refactor(pipelines/cdp): migrate data models to composable NamedTuples with Beam schemas
iht
committed
117147a

Commits on Sep 8, 2026

refactor(pipelines/cdp): remove unused output_schema argument from create_and_run_pipeline
iht
committed
bc1db97
refactor(pipelines/cdp): modularize pipeline components and extract data simulator
iht
committed
1e9b43e
refactor(pipelines/cdp): address review comments and eliminate schema duplication
iht
committed
250a9f2
fix(pipelines/cdp): remove unused imports in test_customer_data_platform
iht
committed
63f3d3c
docs(cdp): document accumulating triggers and BigQuery deduplication queries
iht
committed
72aff06
build(cdp): switch cloudbuild to kaniko executor for modern OCI beam images
iht
committed
625756e
fix(cdp): ensure Storage Write API timestamp compatibility and container packaging
iht
committed
1e055b1