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