From e0507343a460506e6f11cb3b883fc7acf64892ad Mon Sep 17 00:00:00 2001 From: David Clark Date: Tue, 2 Jun 2026 17:22:51 -0400 Subject: [PATCH 1/2] Fix Tinybird link metadata materialized pipe schema --- packages/tinybird/pipes/dub_links_metadata_pipe.pipe | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/tinybird/pipes/dub_links_metadata_pipe.pipe b/packages/tinybird/pipes/dub_links_metadata_pipe.pipe index 505c0f5fd46..a7bf62d3495 100644 --- a/packages/tinybird/pipes/dub_links_metadata_pipe.pipe +++ b/packages/tinybird/pipes/dub_links_metadata_pipe.pipe @@ -21,6 +21,7 @@ SQL > partner_group_id, folder_id, tag_ids, + partner_tag_ids, tenant_id, created_at, deleted @@ -29,4 +30,3 @@ SQL > TYPE materialized DATASOURCE dub_links_metadata_latest - From b371d28d3546a765894ce372038f16522125ba37 Mon Sep 17 00:00:00 2001 From: David Clark Date: Tue, 2 Jun 2026 17:23:17 -0400 Subject: [PATCH 2/2] Mark Tinybird endpoint pipes as TYPE ENDPOINT for TinyBird Forward workspace compatibility --- packages/tinybird/pipes/all_stats.pipe | 3 +-- packages/tinybird/pipes/coordinates_all.pipe | 3 +-- packages/tinybird/pipes/coordinates_sales.pipe | 3 +-- packages/tinybird/pipes/get_api_log_by_id.pipe | 1 + packages/tinybird/pipes/get_api_logs.pipe | 1 + packages/tinybird/pipes/get_api_logs_count.pipe | 1 + packages/tinybird/pipes/get_audit_logs.pipe | 3 +-- packages/tinybird/pipes/get_click_event.pipe | 3 +-- packages/tinybird/pipes/get_framer_lead_events.pipe | 3 +-- packages/tinybird/pipes/get_import_error_logs.pipe | 3 +-- packages/tinybird/pipes/get_lead_event.pipe | 3 +-- packages/tinybird/pipes/get_lead_events.pipe | 3 +-- packages/tinybird/pipes/get_postback_events.pipe | 3 +-- packages/tinybird/pipes/get_webhook_events.pipe | 3 +-- packages/tinybird/pipes/v2_customer_events.pipe | 3 +-- packages/tinybird/pipes/v2_top_programs.pipe | 3 +-- packages/tinybird/pipes/v3_count.pipe | 3 +-- packages/tinybird/pipes/v3_events.pipe | 3 +-- packages/tinybird/pipes/v3_group_by.pipe | 3 +-- packages/tinybird/pipes/v3_group_by_link_country.pipe | 3 +-- packages/tinybird/pipes/v3_group_by_link_metadata.pipe | 3 +-- packages/tinybird/pipes/v3_timeseries.pipe | 3 +-- packages/tinybird/pipes/v3_usage.pipe | 3 +-- packages/tinybird/pipes/v3_usage_latest.pipe | 3 +-- packages/tinybird/pipes/v4_count.pipe | 3 +-- packages/tinybird/pipes/v4_events.pipe | 3 +-- packages/tinybird/pipes/v4_group_by.pipe | 3 +-- packages/tinybird/pipes/v4_group_by_link_metadata.pipe | 3 +-- packages/tinybird/pipes/v4_timeseries.pipe | 3 +-- 29 files changed, 29 insertions(+), 52 deletions(-) diff --git a/packages/tinybird/pipes/all_stats.pipe b/packages/tinybird/pipes/all_stats.pipe index 9e415b97436..87e41bd3c64 100644 --- a/packages/tinybird/pipes/all_stats.pipe +++ b/packages/tinybird/pipes/all_stats.pipe @@ -7,5 +7,4 @@ SQL > (SELECT COUNT(timestamp) FROM dub_click_events_mv) AS clicks, (SELECT COUNT(timestamp) + 42036155 FROM dub_links_metadata) AS links, (SELECT SUM(amount) FROM dub_sale_events_mv) AS sales - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/coordinates_all.pipe b/packages/tinybird/pipes/coordinates_all.pipe index 732f7c376ac..333bcb587d6 100644 --- a/packages/tinybird/pipes/coordinates_all.pipe +++ b/packages/tinybird/pipes/coordinates_all.pipe @@ -92,5 +92,4 @@ SQL > ) ORDER BY timestamp DESC - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/coordinates_sales.pipe b/packages/tinybird/pipes/coordinates_sales.pipe index b10fdfec0aa..7e62cd29af8 100644 --- a/packages/tinybird/pipes/coordinates_sales.pipe +++ b/packages/tinybird/pipes/coordinates_sales.pipe @@ -22,5 +22,4 @@ SQL > AND city != 'Ashburn' ORDER BY timestamp DESC LIMIT 500 - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_api_log_by_id.pipe b/packages/tinybird/pipes/get_api_log_by_id.pipe index 408e796663b..591e8bd109b 100644 --- a/packages/tinybird/pipes/get_api_log_by_id.pipe +++ b/packages/tinybird/pipes/get_api_log_by_id.pipe @@ -20,3 +20,4 @@ SQL > id = {{ String(id) }} AND workspace_id = {{ String(workspaceId) }} LIMIT 1 +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_api_logs.pipe b/packages/tinybird/pipes/get_api_logs.pipe index 44856eac7aa..9d3a73d4e13 100644 --- a/packages/tinybird/pipes/get_api_logs.pipe +++ b/packages/tinybird/pipes/get_api_logs.pipe @@ -31,3 +31,4 @@ SQL > ORDER BY timestamp DESC LIMIT {{ Int32(limit, 100) }} OFFSET {{ Int32(offset, 0) }} +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_api_logs_count.pipe b/packages/tinybird/pipes/get_api_logs_count.pipe index 67f50c44a9f..b5594dcadc2 100644 --- a/packages/tinybird/pipes/get_api_logs_count.pipe +++ b/packages/tinybird/pipes/get_api_logs_count.pipe @@ -49,3 +49,4 @@ SQL > {% if defined(groupBy) and groupBy == 'routePattern' %} count_by_route_pattern {% else %} count {% end %} +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_audit_logs.pipe b/packages/tinybird/pipes/get_audit_logs.pipe index 426501187b2..24e5f6b4d9e 100644 --- a/packages/tinybird/pipes/get_audit_logs.pipe +++ b/packages/tinybird/pipes/get_audit_logs.pipe @@ -24,5 +24,4 @@ SQL > {% if defined(workspaceId) %} AND workspace_id = {{ String(workspaceId) }} {% end %} {% if defined(programId) %} AND program_id = {{ String(programId) }} {% end %} ORDER BY timestamp DESC - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_click_event.pipe b/packages/tinybird/pipes/get_click_event.pipe index 66c6700c2b0..5bf1c85c3f4 100644 --- a/packages/tinybird/pipes/get_click_event.pipe +++ b/packages/tinybird/pipes/get_click_event.pipe @@ -16,5 +16,4 @@ SQL > }} ORDER BY timestamp DESC LIMIT 1 - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_framer_lead_events.pipe b/packages/tinybird/pipes/get_framer_lead_events.pipe index c58575ab64c..ebf6cf0bb69 100644 --- a/packages/tinybird/pipes/get_framer_lead_events.pipe +++ b/packages/tinybird/pipes/get_framer_lead_events.pipe @@ -7,5 +7,4 @@ SQL > WHERE link_id IN {{ Array(linkIds, 'String', ['link_1JWRSXGRTN95H1YCKTC5BM41B','link_1JWQHXN0Y1QBR7X07YQ6MHWTZ']) }} AND customer_id IN {{ Array(customerIds, 'String', ['cus_1JWTHSGTT67WY9NK98QSFJ3M4','cus_1JWTQS8S008Q3VTB8ZRG7AE3W']) }} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_import_error_logs.pipe b/packages/tinybird/pipes/get_import_error_logs.pipe index 1398892652f..c6dce06acd6 100644 --- a/packages/tinybird/pipes/get_import_error_logs.pipe +++ b/packages/tinybird/pipes/get_import_error_logs.pipe @@ -27,5 +27,4 @@ SQL > }} ORDER BY timestamp DESC limit 5000 - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_lead_event.pipe b/packages/tinybird/pipes/get_lead_event.pipe index 60e15fdabdf..2606ba94625 100644 --- a/packages/tinybird/pipes/get_lead_event.pipe +++ b/packages/tinybird/pipes/get_lead_event.pipe @@ -20,5 +20,4 @@ SQL > }} {% if defined(eventName) %} AND event_name = {{ eventName }} {% end %} ORDER BY timestamp DESC - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_lead_events.pipe b/packages/tinybird/pipes/get_lead_events.pipe index 7e329df6339..1de7767c507 100644 --- a/packages/tinybird/pipes/get_lead_events.pipe +++ b/packages/tinybird/pipes/get_lead_events.pipe @@ -8,5 +8,4 @@ SQL > true {% if defined(customerIds) %} AND customer_id IN {{ Array(customerIds, 'String') }} {% end %} ORDER BY timestamp DESC - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_postback_events.pipe b/packages/tinybird/pipes/get_postback_events.pipe index 0e0449862bb..ebf14f8d336 100644 --- a/packages/tinybird/pipes/get_postback_events.pipe +++ b/packages/tinybird/pipes/get_postback_events.pipe @@ -20,5 +20,4 @@ SQL > }} ORDER BY timestamp DESC limit 100 - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/get_webhook_events.pipe b/packages/tinybird/pipes/get_webhook_events.pipe index d6ad4466349..75d3b4a0c95 100644 --- a/packages/tinybird/pipes/get_webhook_events.pipe +++ b/packages/tinybird/pipes/get_webhook_events.pipe @@ -20,5 +20,4 @@ SQL > }} ORDER BY timestamp DESC limit 100 - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v2_customer_events.pipe b/packages/tinybird/pipes/v2_customer_events.pipe index 8589c91b579..dd4ab528b19 100644 --- a/packages/tinybird/pipes/v2_customer_events.pipe +++ b/packages/tinybird/pipes/v2_customer_events.pipe @@ -160,5 +160,4 @@ SQL > ) ORDER BY timestamp DESC, CASE event WHEN 'click' THEN 1 WHEN 'lead' THEN 2 WHEN 'sale' THEN 3 END DESC - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v2_top_programs.pipe b/packages/tinybird/pipes/v2_top_programs.pipe index 88bedfe1667..50df8e31888 100644 --- a/packages/tinybird/pipes/v2_top_programs.pipe +++ b/packages/tinybird/pipes/v2_top_programs.pipe @@ -174,5 +174,4 @@ SQL > {% elif eventType == 'composite' %} top_programs_composite {% else %} top_programs_sales {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_count.pipe b/packages/tinybird/pipes/v3_count.pipe index 234a80b0fce..84d8a97da75 100644 --- a/packages/tinybird/pipes/v3_count.pipe +++ b/packages/tinybird/pipes/v3_count.pipe @@ -318,5 +318,4 @@ FROM {% elif eventType == 'composite' %} count_composite {% else %} count_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_events.pipe b/packages/tinybird/pipes/v3_events.pipe index 1ae0399d215..d95cb9d73ff 100644 --- a/packages/tinybird/pipes/v3_events.pipe +++ b/packages/tinybird/pipes/v3_events.pipe @@ -322,5 +322,4 @@ FROM {% elif eventType == 'sales' %} sale_events {% else %} click_events {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_group_by.pipe b/packages/tinybird/pipes/v3_group_by.pipe index 896d21ee713..509ff2105d4 100644 --- a/packages/tinybird/pipes/v3_group_by.pipe +++ b/packages/tinybird/pipes/v3_group_by.pipe @@ -493,5 +493,4 @@ FROM {% elif eventType == 'composite' %}group_by_composite {% else %} group_by_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_group_by_link_country.pipe b/packages/tinybird/pipes/v3_group_by_link_country.pipe index 77db5a95490..cc5e7fccae6 100644 --- a/packages/tinybird/pipes/v3_group_by_link_country.pipe +++ b/packages/tinybird/pipes/v3_group_by_link_country.pipe @@ -22,5 +22,4 @@ SQL > ORDER BY link_id ASC, clicks DESC - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_group_by_link_metadata.pipe b/packages/tinybird/pipes/v3_group_by_link_metadata.pipe index 870ccfcb5a5..6a5e3ae185d 100644 --- a/packages/tinybird/pipes/v3_group_by_link_metadata.pipe +++ b/packages/tinybird/pipes/v3_group_by_link_metadata.pipe @@ -296,5 +296,4 @@ FROM {% elif eventType == 'composite' %}group_by_link_metadata_composite {% else %} group_by_link_metadata_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_timeseries.pipe b/packages/tinybird/pipes/v3_timeseries.pipe index 56b88210ce0..3dcfcf5f314 100644 --- a/packages/tinybird/pipes/v3_timeseries.pipe +++ b/packages/tinybird/pipes/v3_timeseries.pipe @@ -434,5 +434,4 @@ FROM {% elif eventType == 'composite' %} timeseries_composite {% else %} timeseries_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_usage.pipe b/packages/tinybird/pipes/v3_usage.pipe index 9ff55a557f6..f6d0ee8a89f 100644 --- a/packages/tinybird/pipes/v3_usage.pipe +++ b/packages/tinybird/pipes/v3_usage.pipe @@ -140,5 +140,4 @@ SQL > % SELECT * FROM {% if resource == 'events' %} usage_events {% else %} usage_links {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v3_usage_latest.pipe b/packages/tinybird/pipes/v3_usage_latest.pipe index be600a137b7..45aa75d0a4b 100644 --- a/packages/tinybird/pipes/v3_usage_latest.pipe +++ b/packages/tinybird/pipes/v3_usage_latest.pipe @@ -144,5 +144,4 @@ SQL > % SELECT * FROM {% if resource == 'events' %} usage_events {% else %} usage_links {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v4_count.pipe b/packages/tinybird/pipes/v4_count.pipe index a386de10f8e..18355daf6c1 100644 --- a/packages/tinybird/pipes/v4_count.pipe +++ b/packages/tinybird/pipes/v4_count.pipe @@ -622,5 +622,4 @@ SQL > {% elif eventType == 'composite' %} count_composite {% else %} count_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v4_events.pipe b/packages/tinybird/pipes/v4_events.pipe index 29cc984f801..c8e40e9e0cd 100644 --- a/packages/tinybird/pipes/v4_events.pipe +++ b/packages/tinybird/pipes/v4_events.pipe @@ -632,5 +632,4 @@ SQL > {% elif eventType == 'sales' %} sale_events {% else %} click_events {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v4_group_by.pipe b/packages/tinybird/pipes/v4_group_by.pipe index 6960773b70a..093fe0d8219 100644 --- a/packages/tinybird/pipes/v4_group_by.pipe +++ b/packages/tinybird/pipes/v4_group_by.pipe @@ -821,5 +821,4 @@ SQL > {% elif eventType == 'composite' %}group_by_composite {% else %} group_by_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v4_group_by_link_metadata.pipe b/packages/tinybird/pipes/v4_group_by_link_metadata.pipe index 96f495612ac..5848c7a4767 100644 --- a/packages/tinybird/pipes/v4_group_by_link_metadata.pipe +++ b/packages/tinybird/pipes/v4_group_by_link_metadata.pipe @@ -587,5 +587,4 @@ SQL > {% elif eventType == 'composite' %}group_by_link_metadata_composite {% else %} group_by_link_metadata_clicks {% end %} - - +TYPE ENDPOINT diff --git a/packages/tinybird/pipes/v4_timeseries.pipe b/packages/tinybird/pipes/v4_timeseries.pipe index aac17a1a648..99659c371dc 100644 --- a/packages/tinybird/pipes/v4_timeseries.pipe +++ b/packages/tinybird/pipes/v4_timeseries.pipe @@ -764,5 +764,4 @@ SQL > {% elif eventType == 'composite' %} timeseries_composite {% else %} timeseries_clicks {% end %} - - +TYPE ENDPOINT