Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
58 changes: 45 additions & 13 deletions services/libs/tinybird/pipes/health_score_copy.pipe
Original file line number Diff line number Diff line change
Expand Up @@ -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 >
Expand Down
2 changes: 1 addition & 1 deletion services/libs/tinybird/pipes/health_score_retention.pipe
Original file line number Diff line number Diff line change
Expand Up @@ -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 >
Expand Down
6 changes: 4 additions & 2 deletions services/libs/tinybird/pipes/health_score_security.pipe
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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
Expand Down
Loading