From 349d233891b705563440ca79135a71a63f05b112 Mon Sep 17 00:00:00 2001 From: anilb Date: Mon, 3 Aug 2026 13:53:25 +0200 Subject: [PATCH] fix: health score copy joins Signed-off-by: anilb --- .../tinybird/pipes/health_score_copy.pipe | 58 ++++++++++++++----- .../pipes/health_score_retention.pipe | 2 +- .../tinybird/pipes/health_score_security.pipe | 6 +- 3 files changed, 50 insertions(+), 16 deletions(-) diff --git a/services/libs/tinybird/pipes/health_score_copy.pipe b/services/libs/tinybird/pipes/health_score_copy.pipe index 155bcab73e..095b10cb4c 100644 --- a/services/libs/tinybird/pipes/health_score_copy.pipe +++ b/services/libs/tinybird/pipes/health_score_copy.pipe @@ -49,19 +49,51 @@ SQL > health_score_security.securityCategoryPercentage as securityCategoryPercentage, health_score_security.securityPercentage as securityPercentage FROM health_score_copy_project_repo_deduplicated - LEFT JOIN health_score_active_contributors USING (segmentId) - LEFT JOIN health_score_contributor_dependency USING (segmentId) - LEFT JOIN health_score_organization_dependency USING (segmentId) - LEFT JOIN health_score_retention USING (segmentId) - LEFT JOIN health_score_stars USING (segmentId) - LEFT JOIN health_score_forks USING (segmentId) - LEFT JOIN health_score_issues_resolution USING (segmentId) - LEFT JOIN health_score_pull_requests USING (segmentId) - LEFT JOIN health_score_merge_lead_time USING (segmentId) - LEFT JOIN health_score_active_days USING (segmentId) - LEFT JOIN health_score_contributions_outside_work_hours USING (segmentId) - LEFT JOIN health_score_search_volume USING (id) - LEFT JOIN health_score_security USING (id) + LEFT JOIN + health_score_active_contributors + ON health_score_copy_project_repo_deduplicated.segmentId + = health_score_active_contributors.segmentId + LEFT JOIN + health_score_contributor_dependency + ON health_score_copy_project_repo_deduplicated.segmentId + = health_score_contributor_dependency.segmentId + LEFT JOIN + health_score_organization_dependency + ON health_score_copy_project_repo_deduplicated.segmentId + = health_score_organization_dependency.segmentId + LEFT JOIN + health_score_retention + ON health_score_copy_project_repo_deduplicated.segmentId = health_score_retention.segmentId + LEFT JOIN + health_score_stars + ON health_score_copy_project_repo_deduplicated.segmentId = health_score_stars.segmentId + LEFT JOIN + health_score_forks + ON health_score_copy_project_repo_deduplicated.segmentId = health_score_forks.segmentId + LEFT JOIN + health_score_issues_resolution + ON health_score_copy_project_repo_deduplicated.segmentId + = health_score_issues_resolution.segmentId + LEFT JOIN + health_score_pull_requests + ON health_score_copy_project_repo_deduplicated.segmentId = health_score_pull_requests.segmentId + LEFT JOIN + health_score_merge_lead_time + ON health_score_copy_project_repo_deduplicated.segmentId + = health_score_merge_lead_time.segmentId + LEFT JOIN + health_score_active_days + ON health_score_copy_project_repo_deduplicated.segmentId = health_score_active_days.segmentId + LEFT JOIN + health_score_contributions_outside_work_hours + ON health_score_copy_project_repo_deduplicated.segmentId + = health_score_contributions_outside_work_hours.segmentId + LEFT JOIN + health_score_search_volume + ON health_score_copy_project_repo_deduplicated.id = health_score_search_volume.id + LEFT JOIN + health_score_security + ON health_score_copy_project_repo_deduplicated.id = health_score_security.id NODE health_score_copy_result SQL > diff --git a/services/libs/tinybird/pipes/health_score_retention.pipe b/services/libs/tinybird/pipes/health_score_retention.pipe index 9e5e5629dc..bb7430c4b6 100644 --- a/services/libs/tinybird/pipes/health_score_retention.pipe +++ b/services/libs/tinybird/pipes/health_score_retention.pipe @@ -128,7 +128,7 @@ SQL > 0 ) AS retentionRate FROM health_score_retention_current_quarter AS cur - LEFT JOIN health_score_retention_previous_quarter AS prev USING (segmentId) + LEFT JOIN health_score_retention_previous_quarter AS prev ON cur.segmentId = prev.segmentId NODE health_score_retention_benchmark SQL > diff --git a/services/libs/tinybird/pipes/health_score_security.pipe b/services/libs/tinybird/pipes/health_score_security.pipe index 7380518a57..469bbb27c2 100644 --- a/services/libs/tinybird/pipes/health_score_security.pipe +++ b/services/libs/tinybird/pipes/health_score_security.pipe @@ -23,7 +23,7 @@ NODE health_score_security_check_pass_rate SQL > SELECT id, - repo, + security_deduplicated_merged_ds.repo AS repo, category, controlId, insightsProjectSlug, @@ -34,7 +34,9 @@ SQL > length(arrayFilter(x -> x['result'] = 'Failed', filteredAssessments)) AS failedAssessments, length(arrayFilter(x -> x['result'] = 'Passed', filteredAssessments)) AS passedAssessments FROM security_deduplicated_merged_ds - JOIN health_score_security_project_repos USING (repo) + JOIN + health_score_security_project_repos + ON security_deduplicated_merged_ds.repo = health_score_security_project_repos.repo WHERE category not in ('Documentation', 'Vulnerability Management') AND insightsProjectSlug = slug NODE health_score_security_category_pass_rate