diff --git a/services/libs/tinybird/pipes/health_score_retention.pipe b/services/libs/tinybird/pipes/health_score_retention.pipe index c679eab798..a679a75687 100644 --- a/services/libs/tinybird/pipes/health_score_retention.pipe +++ b/services/libs/tinybird/pipes/health_score_retention.pipe @@ -8,6 +8,7 @@ SQL > memberId != '' AND segmentId = (SELECT segmentId FROM segments_filtered) AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded) + AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered) {% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %} {% if defined(endDate) %} AND timestamp >= toStartOfQuarter( @@ -31,6 +32,7 @@ SQL > FROM activityRelations_deduplicated_cleaned_bucket_union WHERE memberId != '' AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded) + AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered) {% if defined(endDate) %} AND timestamp >= toStartOfQuarter( parseDateTimeBestEffort( @@ -60,6 +62,7 @@ SQL > memberId != '' AND segmentId = (SELECT segmentId FROM segments_filtered) AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded) + AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered) {% if defined(endDate) %} AND timestamp >= toStartOfQuarter( parseDateTimeBestEffort( @@ -83,6 +86,7 @@ SQL > FROM activityRelations_deduplicated_cleaned_bucket_union WHERE memberId != '' AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded) + AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered) {% if defined(endDate) %} AND timestamp >= toStartOfQuarter( parseDateTimeBestEffort(