From 5e181f86747195ee9c23c01ad98985be5c685f40 Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 10:10:30 +0100 Subject: [PATCH 01/10] fix: active maintianers count in active contributors widget Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/active_contributors.pipe | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/services/libs/tinybird/pipes/active_contributors.pipe b/services/libs/tinybird/pipes/active_contributors.pipe index d1b06583d2..84ec78ecac 100644 --- a/services/libs/tinybird/pipes/active_contributors.pipe +++ b/services/libs/tinybird/pipes/active_contributors.pipe @@ -52,10 +52,11 @@ SQL > NODE maintainers_count SQL > % - SELECT uniq(memberId) AS maintainerCount + SELECT uniq(case when memberId != '' then memberId else null end) AS maintainerCount FROM maintainers_roles_copy_ds WHERE insightsProjectId = (SELECT insightsProjectId FROM segments_filtered) + AND role = 'maintainer' {% if defined(repos) %} AND repoUrl IN {{ Array(repos, 'String', description="Filter maintainer repo list", required=False) }} @@ -73,7 +74,7 @@ SQL > OR endDate >= {% if defined(startDate) %} {{ DateTime(startDate, description="Filter maintainer start date", required=False) }} - {% else %} toDateTime64('1970-01-01 00:00:00', 3) + {% else %} now() {% end %} ) From de67495dcabc43123975b37270fd0442e7a8c301 Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 10:23:18 +0100 Subject: [PATCH 02/10] fix: deduplication of memberIds in maintainers deduplication pipe Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/maintainers_roles_copy.pipe | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index c0e561f391..601676e652 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -7,7 +7,10 @@ SQL > NODE maintainers_roles_copy_member_identities_deduplicated SQL > - SELECT id, memberId FROM memberIdentities FINAL WHERE isNull (deletedAt) + SELECT id, argMax(memberId, updatedAt) AS memberId + FROM memberIdentities + WHERE isNull (deletedAt) + GROUP BY id NODE maintainers_roles_copy_maintainers_deduplicated SQL > From 28cd6e734dd68b9bd40a2ec302eb6ebe6eca5b6d Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 10:51:52 +0100 Subject: [PATCH 03/10] fix: PR comments Signed-off-by: Joana Maia --- .../libs/tinybird/pipes/active_contributors.pipe | 3 ++- .../tinybird/pipes/maintainers_roles_copy.pipe | 14 ++++++++++---- 2 files changed, 12 insertions(+), 5 deletions(-) diff --git a/services/libs/tinybird/pipes/active_contributors.pipe b/services/libs/tinybird/pipes/active_contributors.pipe index 84ec78ecac..d72903f619 100644 --- a/services/libs/tinybird/pipes/active_contributors.pipe +++ b/services/libs/tinybird/pipes/active_contributors.pipe @@ -52,7 +52,7 @@ SQL > NODE maintainers_count SQL > % - SELECT uniq(case when memberId != '' then memberId else null end) AS maintainerCount + SELECT uniqIf(memberId, memberId != '') AS maintainerCount FROM maintainers_roles_copy_ds WHERE insightsProjectId = (SELECT insightsProjectId FROM segments_filtered) @@ -74,6 +74,7 @@ SQL > OR endDate >= {% if defined(startDate) %} {{ DateTime(startDate, description="Filter maintainer start date", required=False) }} + {% elif defined(endDate) %} toDateTime64('1970-01-01 00:00:00', 3) {% else %} now() {% end %} ) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index 601676e652..e58c4fc699 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -7,10 +7,16 @@ SQL > NODE maintainers_roles_copy_member_identities_deduplicated SQL > - SELECT id, argMax(memberId, updatedAt) AS memberId - FROM memberIdentities - WHERE isNull (deletedAt) - GROUP BY id + SELECT id, memberId + FROM ( + SELECT + id, + argMax(memberId, updatedAt) AS memberId, + argMax(deletedAt, updatedAt) AS deletedAt + FROM memberIdentities + GROUP BY id + ) + WHERE isNull(deletedAt) NODE maintainers_roles_copy_maintainers_deduplicated SQL > From 9355b05bcc601d91b63a12ebace3572fe40bc53c Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 10:56:13 +0100 Subject: [PATCH 04/10] fix: formatting Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/active_contributors.pipe | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/services/libs/tinybird/pipes/active_contributors.pipe b/services/libs/tinybird/pipes/active_contributors.pipe index d72903f619..bee53a0e11 100644 --- a/services/libs/tinybird/pipes/active_contributors.pipe +++ b/services/libs/tinybird/pipes/active_contributors.pipe @@ -55,8 +55,7 @@ SQL > SELECT uniqIf(memberId, memberId != '') AS maintainerCount FROM maintainers_roles_copy_ds WHERE - insightsProjectId = (SELECT insightsProjectId FROM segments_filtered) - AND role = 'maintainer' + insightsProjectId = (SELECT insightsProjectId FROM segments_filtered) AND role = 'maintainer' {% if defined(repos) %} AND repoUrl IN {{ Array(repos, 'String', description="Filter maintainer repo list", required=False) }} From 7e9e769432b74a6dbda155c8adf3c854da26e77a Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 11:10:48 +0100 Subject: [PATCH 05/10] fix: formatting and alias Signed-off-by: Joana Maia --- .../tinybird/pipes/maintainers_roles_copy.pipe | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index e58c4fc699..1f29692f00 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -8,15 +8,14 @@ SQL > NODE maintainers_roles_copy_member_identities_deduplicated SQL > SELECT id, memberId - FROM ( - SELECT - id, - argMax(memberId, updatedAt) AS memberId, - argMax(deletedAt, updatedAt) AS deletedAt - FROM memberIdentities - GROUP BY id - ) - WHERE isNull(deletedAt) + FROM + ( + SELECT + id, argMax(memberId, updatedAt) AS memberId, argMax(deletedAt, updatedAt) AS deletedAt + FROM memberIdentities + GROUP BY id + ) AS deduped + WHERE isNull (deduped.deletedAt) NODE maintainers_roles_copy_maintainers_deduplicated SQL > From 943a090021aee3e6150d36d61abc673460b84de9 Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 11:29:58 +0100 Subject: [PATCH 06/10] fix: address PR comments Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/maintainers_roles_copy.pipe | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index 1f29692f00..079a4c0fce 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -11,7 +11,9 @@ SQL > FROM ( SELECT - id, argMax(memberId, updatedAt) AS memberId, argMax(deletedAt, updatedAt) AS deletedAt + id, + argMax((memberId, deletedAt), updatedAt).1 AS memberId, + argMax((memberId, deletedAt), updatedAt).2 AS deletedAt FROM memberIdentities GROUP BY id ) AS deduped From b29adffc296663db9015f0467b1143df16f16c6d Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 11:39:37 +0100 Subject: [PATCH 07/10] fix: formatting Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/maintainers_roles_copy.pipe | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index 079a4c0fce..e86c34360e 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -12,8 +12,8 @@ SQL > ( SELECT id, - argMax((memberId, deletedAt), updatedAt).1 AS memberId, - argMax((memberId, deletedAt), updatedAt).2 AS deletedAt + argMax((memberId, deletedAt), updatedAt) .1 AS memberId, + argMax((memberId, deletedAt), updatedAt) .2 AS deletedAt FROM memberIdentities GROUP BY id ) AS deduped From 5417b3d6ac6e60fda46f30bc52152158f2307526 Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 11:46:42 +0100 Subject: [PATCH 08/10] fix: address PR comments Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/maintainers_roles_copy.pipe | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index e86c34360e..079a4c0fce 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -12,8 +12,8 @@ SQL > ( SELECT id, - argMax((memberId, deletedAt), updatedAt) .1 AS memberId, - argMax((memberId, deletedAt), updatedAt) .2 AS deletedAt + argMax((memberId, deletedAt), updatedAt).1 AS memberId, + argMax((memberId, deletedAt), updatedAt).2 AS deletedAt FROM memberIdentities GROUP BY id ) AS deduped From 76304e1284adc03b881a1a57447c5d9306c8afd1 Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 11:50:39 +0100 Subject: [PATCH 09/10] fix: formatting Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/maintainers_roles_copy.pipe | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index 079a4c0fce..e86c34360e 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -12,8 +12,8 @@ SQL > ( SELECT id, - argMax((memberId, deletedAt), updatedAt).1 AS memberId, - argMax((memberId, deletedAt), updatedAt).2 AS deletedAt + argMax((memberId, deletedAt), updatedAt) .1 AS memberId, + argMax((memberId, deletedAt), updatedAt) .2 AS deletedAt FROM memberIdentities GROUP BY id ) AS deduped From d753f2c697a08231d1ccf790782a6b202031e7be Mon Sep 17 00:00:00 2001 From: Joana Maia Date: Wed, 17 Jun 2026 11:53:35 +0100 Subject: [PATCH 10/10] fix: pipe Signed-off-by: Joana Maia --- services/libs/tinybird/pipes/maintainers_roles_copy.pipe | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe index e86c34360e..3fd87baba0 100644 --- a/services/libs/tinybird/pipes/maintainers_roles_copy.pipe +++ b/services/libs/tinybird/pipes/maintainers_roles_copy.pipe @@ -12,9 +12,9 @@ SQL > ( SELECT id, - argMax((memberId, deletedAt), updatedAt) .1 AS memberId, - argMax((memberId, deletedAt), updatedAt) .2 AS deletedAt - FROM memberIdentities + argMax((mi.memberId, mi.deletedAt), mi.updatedAt) .1 AS memberId, + argMax((mi.memberId, mi.deletedAt), mi.updatedAt) .2 AS deletedAt + FROM memberIdentities as mi GROUP BY id ) AS deduped WHERE isNull (deduped.deletedAt)