feat: filter by snapshot id initial snapshot for member/organizations (#4018)

ulemons · web-flow · commit a45678738c84 · 2026-04-13T15:51:18.000+02:00
Signed-off-by: Umberto Sgueglia &lt;usgueglia@contractor.linuxfoundation.org&gt;
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
@@ -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
@@ -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
