feat: route collection-scoped activity queries to single bucket (IN-1231)

services/libs/tinybird/pipes/activities_filtered.pipe

@@ -16,6 +16,9 @@ DESCRIPTION >
     - `activity_types`: Optional array of activity types (e.g., ['authored-commit', 'co-authored-commit'])
     - `includeCodeContributions`: Optional boolean to include code contribution activities. Defaults to 1. Set to 0 to exclude. Inherited from activityTypes_filtered.
     - `includeCollaborations`: Optional boolean to include or exclude collaboration activities. Inherited from activityTypes_filtered.
+    - `bucketId`: Pre-resolved collection bucket id (from `collection_buckets.pipe`), required alongside `collectionSlug`.
+    Routes directly to the single matching bucket table. If `collectionSlug` is given without `bucketId`, the pipe
+    returns no rows rather than falling back to a 10-way union scan — callers must resolve `bucketId` first.
     - Response: `id` (activityId), `timestamp`, `type`, `platform`, `memberId`, `organizationId`, `segmentId`.
     - This pipe is consumed by many of downstream pipes and widgets across the platform for consistent activity filtering.
     - Performance is optimized through proper sorting keys on `segmentId`, `timestamp`, `type`, `platform`, and `memberId` in the source datasource.
@@ -27,12 +30,16 @@ SQL >
     %
     SELECT activityId as id, timestamp, type, platform, memberId, organizationId, segmentId
     FROM
-        {% if defined(collectionSlug) %} activityRelations_collection_bucket_union
+        {% if defined(collectionSlug) %} activityRelations_collection_bucket_routing
         {% else %} activityRelations_bucket_routing
         {% end %} as a
     where
         {% if defined(collectionSlug) %}
-            segmentId IN (SELECT segmentId FROM segments_filtered_by_collection)
+            {% if defined(bucketId) %}
+                segmentId IN (SELECT segmentId FROM segments_filtered_by_collection)
+                AND a.collectionSlug = {{ String(collectionSlug) }}
+            {% else %} 1 = 0
+            {% end %}
         {% else %} segmentId = (SELECT segmentId FROM segments_filtered)
         {% end %}
         {% if defined(startDate) %}

services/libs/tinybird/pipes/activityRelations_collection_bucket_routing.pipe

@@ -0,0 +1,17 @@
+NODE activityRelations_collection_bucket_routing_2
+SQL >
+    %
+    SELECT selected_bucket.*
+    FROM
+        {% if bucketId == '0' %} activityRelations_collection_deduplicated_cleaned_bucket_0_ds
+        {% elif bucketId == '1' %} activityRelations_collection_deduplicated_cleaned_bucket_1_ds
+        {% elif bucketId == '2' %} activityRelations_collection_deduplicated_cleaned_bucket_2_ds
+        {% elif bucketId == '3' %} activityRelations_collection_deduplicated_cleaned_bucket_3_ds
+        {% elif bucketId == '4' %} activityRelations_collection_deduplicated_cleaned_bucket_4_ds
+        {% elif bucketId == '5' %} activityRelations_collection_deduplicated_cleaned_bucket_5_ds
+        {% elif bucketId == '6' %} activityRelations_collection_deduplicated_cleaned_bucket_6_ds
+        {% elif bucketId == '7' %} activityRelations_collection_deduplicated_cleaned_bucket_7_ds
+        {% elif bucketId == '8' %} activityRelations_collection_deduplicated_cleaned_bucket_8_ds
+        {% elif bucketId == '9' %} activityRelations_collection_deduplicated_cleaned_bucket_9_ds
+        {% else %} activityRelations_collection_deduplicated_cleaned_bucket_0_ds
+        {% end %} as selected_bucket