From 4ef0a6c92acd1cdcfe2032b792236d292849f145 Mon Sep 17 00:00:00 2001 From: Umberto Sgueglia Date: Mon, 13 Apr 2026 15:42:29 +0200 Subject: [PATCH] feat: filter by snapshot id initial snapshot for member/organizations Signed-off-by: Umberto Sgueglia --- .../pipes/cdp_member_segment_aggregates_initial_snapshot.pipe | 1 + .../cdp_organization_segment_aggregates_initial_snapshot.pipe | 1 + 2 files changed, 2 insertions(+) diff --git a/services/libs/tinybird/pipes/cdp_member_segment_aggregates_initial_snapshot.pipe b/services/libs/tinybird/pipes/cdp_member_segment_aggregates_initial_snapshot.pipe index b6a69804fd..cd6f260052 100644 --- a/services/libs/tinybird/pipes/cdp_member_segment_aggregates_initial_snapshot.pipe +++ b/services/libs/tinybird/pipes/cdp_member_segment_aggregates_initial_snapshot.pipe @@ -12,6 +12,7 @@ SQL > maxState(act.updatedAt) as lastActivityUpdatedAtState, max(act.updatedAt) as updatedAt FROM activityRelations_enriched_deduplicated_ds act + WHERE snapshotId = (SELECT max(snapshotId) FROM activityRelations_enriched_deduplicated_ds) GROUP BY segmentId, memberId TYPE COPY diff --git a/services/libs/tinybird/pipes/cdp_organization_segment_aggregates_initial_snapshot.pipe b/services/libs/tinybird/pipes/cdp_organization_segment_aggregates_initial_snapshot.pipe index e1e84adaed..4dfc7419cd 100644 --- a/services/libs/tinybird/pipes/cdp_organization_segment_aggregates_initial_snapshot.pipe +++ b/services/libs/tinybird/pipes/cdp_organization_segment_aggregates_initial_snapshot.pipe @@ -13,6 +13,7 @@ SQL > maxState(act.updatedAt) as lastActivityUpdatedAtState, max(act.updatedAt) as updatedAt FROM activityRelations_enriched_deduplicated_ds act + WHERE snapshotId = (SELECT max(snapshotId) FROM activityRelations_enriched_deduplicated_ds) GROUP BY segmentId, organizationId TYPE COPY