From 87be7ea57a755ee6a54635584ff07f9139cd33f3 Mon Sep 17 00:00:00 2001 From: Max Date: Wed, 29 Jul 2026 21:43:55 +0800 Subject: [PATCH] fix: update HTTP/TCP latency pipes to use v1 MVs (#2498) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * fix: update HTTP/TCP latency pipes to use v1 MVs for private location data The /monitors list page on status pages fetches latency data via getMetricsLatencyMultiProcedure, which queries Tinybird pipes that were pointing to mv__http_1d__v0 / mv__tcp_1d__v0 materialized views. These v0 views only include cloud checker data. The v1 views (mv__http_1d__v1 / mv__tcp_1d__v1) were created to include private location monitor data, so private location monitors now show latency graphs on the status page monitors list. DNS already queries dns_response__v0 directly (no MV), so no change needed. * fix: update single-monitor latency pipes to use v1 MVs Fixes P1: single-monitor latency v1 pipes still used v0 MVs. - endpoint__http_metrics_latency_1d__v1.pipe: v0 → v1 - endpoint__http_metrics_latency_7d__v1.pipe: v0 → v1 - endpoint__tcp_metrics_latency_1d__v1.pipe: v0 → v1 Fixes empty graphs on status page detail pages for private location monitors. * fix: update regions pipe to use v1 MV for private location data - endpoint__http_metrics_regions_7d__v0.pipe: v0 → v1 Fixes empty Region Latency tab on status page detail pages. * fix: update TCP by_interval pipe to use v1 MV for private location data - endpoint__tcp_metrics_by_interval_7d.pipe: v0 → v1 Fixes empty Region Latency tab on TCP monitor detail pages. * fix: rename TCP by_interval pipe files to add __v0 suffix for consistency Renamed 5 TCP pipe files to match HTTP pipe naming convention: - endpoint__tcp_metrics_by_interval_1d.pipe → __v0.pipe - endpoint__tcp_metrics_by_interval_7d.pipe → __v0.pipe - endpoint__tcp_metrics_by_interval_14d.pipe → __v0.pipe - endpoint__tcp_metrics_by_interval_30d.pipe → __v0.pipe - endpoint__tcp_metrics_by_interval_90d.pipe → __v0.pipe This makes TCP pipes consistent with HTTP pipes which already use version suffixes. The client.ts references were correct all along. --- .../endpoints/endpoint__http_metrics_latency_1d__v1.pipe | 2 +- .../endpoints/endpoint__http_metrics_latency_1d_multi__v1.pipe | 2 +- .../endpoints/endpoint__http_metrics_latency_7d__v1.pipe | 2 +- .../endpoints/endpoint__http_metrics_regions_7d__v0.pipe | 2 +- ..._14d.pipe => endpoint__tcp_metrics_by_interval_14d__v0.pipe} | 0 ...al_1d.pipe => endpoint__tcp_metrics_by_interval_1d__v0.pipe} | 0 ..._30d.pipe => endpoint__tcp_metrics_by_interval_30d__v0.pipe} | 0 ...al_7d.pipe => endpoint__tcp_metrics_by_interval_7d__v0.pipe} | 2 +- ..._90d.pipe => endpoint__tcp_metrics_by_interval_90d__v0.pipe} | 0 .../endpoints/endpoint__tcp_metrics_latency_1d__v1.pipe | 2 +- .../endpoints/endpoint__tcp_metrics_latency_1d_multi__v1.pipe | 2 +- 11 files changed, 7 insertions(+), 7 deletions(-) rename packages/tinybird/endpoints/{endpoint__tcp_metrics_by_interval_14d.pipe => endpoint__tcp_metrics_by_interval_14d__v0.pipe} (100%) rename packages/tinybird/endpoints/{endpoint__tcp_metrics_by_interval_1d.pipe => endpoint__tcp_metrics_by_interval_1d__v0.pipe} (100%) rename packages/tinybird/endpoints/{endpoint__tcp_metrics_by_interval_30d.pipe => endpoint__tcp_metrics_by_interval_30d__v0.pipe} (100%) rename packages/tinybird/endpoints/{endpoint__tcp_metrics_by_interval_7d.pipe => endpoint__tcp_metrics_by_interval_7d__v0.pipe} (96%) rename packages/tinybird/endpoints/{endpoint__tcp_metrics_by_interval_90d.pipe => endpoint__tcp_metrics_by_interval_90d__v0.pipe} (100%) diff --git a/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d__v1.pipe b/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d__v1.pipe index f6d0e812..d8288ac9 100644 --- a/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d__v1.pipe +++ b/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d__v1.pipe @@ -14,7 +14,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__http_1d__v0 + FROM mv__http_1d__v1 WHERE monitorId = {{ String(monitorId, '1', required=True) }} GROUP BY h diff --git a/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d_multi__v1.pipe b/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d_multi__v1.pipe index 94dd1726..746c76ca 100644 --- a/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d_multi__v1.pipe +++ b/packages/tinybird/endpoints/endpoint__http_metrics_latency_1d_multi__v1.pipe @@ -15,7 +15,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__http_1d__v0 + FROM mv__http_1d__v1 WHERE monitorId IN {{ Array(monitorIds, 'String', '1,666') }} GROUP BY h, monitorId diff --git a/packages/tinybird/endpoints/endpoint__http_metrics_latency_7d__v1.pipe b/packages/tinybird/endpoints/endpoint__http_metrics_latency_7d__v1.pipe index be694599..5631bb5d 100644 --- a/packages/tinybird/endpoints/endpoint__http_metrics_latency_7d__v1.pipe +++ b/packages/tinybird/endpoints/endpoint__http_metrics_latency_7d__v1.pipe @@ -14,7 +14,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__http_7d__v0 + FROM mv__http_7d__v1 WHERE monitorId = {{ String(monitorId, '1', required=True) }} GROUP BY h diff --git a/packages/tinybird/endpoints/endpoint__http_metrics_regions_7d__v0.pipe b/packages/tinybird/endpoints/endpoint__http_metrics_regions_7d__v0.pipe index 6a42de62..0b2a50e7 100644 --- a/packages/tinybird/endpoints/endpoint__http_metrics_regions_7d__v0.pipe +++ b/packages/tinybird/endpoints/endpoint__http_metrics_regions_7d__v0.pipe @@ -13,7 +13,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__http_7d__v0 + FROM mv__http_7d__v1 WHERE monitorId = {{ String(monitorId, '1', required=True) }} {% if regions %} AND region IN {{ Array(regions, 'String', 'ams,fra') }} {% end %} diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_14d.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_14d__v0.pipe similarity index 100% rename from packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_14d.pipe rename to packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_14d__v0.pipe diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_1d.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_1d__v0.pipe similarity index 100% rename from packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_1d.pipe rename to packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_1d__v0.pipe diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_30d.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_30d__v0.pipe similarity index 100% rename from packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_30d.pipe rename to packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_30d__v0.pipe diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_7d.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_7d__v0.pipe similarity index 96% rename from packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_7d.pipe rename to packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_7d__v0.pipe index 77e3011a..d6e469f2 100644 --- a/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_7d.pipe +++ b/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_7d__v0.pipe @@ -18,7 +18,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__tcp_7d__v0 + FROM mv__tcp_7d__v1 WHERE monitorId = {{ String(monitorId, '4433', required=True) }} GROUP BY h, region diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_90d.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_90d__v0.pipe similarity index 100% rename from packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_90d.pipe rename to packages/tinybird/endpoints/endpoint__tcp_metrics_by_interval_90d__v0.pipe diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d__v1.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d__v1.pipe index 12ac8542..10d81b99 100644 --- a/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d__v1.pipe +++ b/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d__v1.pipe @@ -14,7 +14,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__tcp_1d__v0 + FROM mv__tcp_1d__v1 WHERE monitorId = {{ String(monitorId, '4433', required=True) }} GROUP BY h diff --git a/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d_multi__v1.pipe b/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d_multi__v1.pipe index 032ea6ec..2f3b5e27 100644 --- a/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d_multi__v1.pipe +++ b/packages/tinybird/endpoints/endpoint__tcp_metrics_latency_1d_multi__v1.pipe @@ -15,7 +15,7 @@ SQL > round(quantile(0.90)(latency)) as p90Latency, round(quantile(0.95)(latency)) as p95Latency, round(quantile(0.99)(latency)) as p99Latency - FROM mv__tcp_1d__v0 + FROM mv__tcp_1d__v1 WHERE monitorId IN {{ Array(monitorIds, 'String', '4433') }} GROUP BY h, monitorId -- 2.51.2