Skip to content

Commit cd2abde

Browse files
authored
chore: deprecate insightsProject.repos from remaining pipes [CM-915] (#3819)
1 parent 45162cf commit cd2abde

3 files changed

Lines changed: 21 additions & 15 deletions

File tree

services/libs/tinybird/pipes/health_score_security.pipe

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,18 @@
11
NODE health_score_security_project_repos
22
SQL >
33
%
4-
SELECT id, repo AS repo, slug
5-
FROM insightsProjects FINAL ARRAY
6-
JOIN repositories AS repo
4+
SELECT i.id, r.url AS repo, i.slug
5+
FROM insightsProjects i FINAL
6+
JOIN repositories r FINAL ON r.insightsProjectId = i.id
77
WHERE
8-
isNull (deletedAt)
8+
isNull(i.deletedAt)
9+
AND isNull(r.deletedAt)
10+
AND r.enabled = true
911
{% if defined(project) %}
10-
AND id = (SELECT insightsProjectId FROM segments_filtered)
11-
AND repo in (select arrayJoin(repositories) from segments_filtered)
12+
AND i.id = (SELECT insightsProjectId FROM segments_filtered)
13+
AND r.url in (select arrayJoin(repositories) from segments_filtered)
1214
{% if defined(repos) %}
13-
AND repo
15+
AND r.url
1416
IN {{ Array(repos, 'String', description="Filter activity repo list", required=False) }}
1517
{% end %}
1618
{% end %}

services/libs/tinybird/pipes/maintainers_roles_copy.pipe

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,11 @@
11
NODE maintainers_roles_copy_project_repos
22
SQL >
3-
SELECT id, repo AS repository
4-
FROM insightsProjects ARRAY
5-
JOIN repositories AS repo
6-
where isNull (deletedAt)
3+
SELECT i.id, r.url AS repository
4+
FROM insightsProjects i FINAL
5+
JOIN repositories r FINAL ON r.insightsProjectId = i.id
6+
WHERE isNull(i.deletedAt)
7+
AND isNull(r.deletedAt)
8+
AND r.enabled = true
79

810
NODE maintainers_roles_copy_member_identities_deduplicated
911
SQL >

services/libs/tinybird/pipes/segments_aggregates_with_ids_copy.pipe

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,10 +43,12 @@ SQL >
4343

4444
NODE segments_aggregates_with_ids_copy_flatten_project_deduplicated
4545
SQL >
46-
SELECT id, repo AS repository
47-
FROM insightsProjects FINAL ARRAY
48-
JOIN repositories AS repo
49-
where isNull (insightsProjects.deletedAt)
46+
SELECT i.id, r.url AS repository
47+
FROM insightsProjects i FINAL
48+
JOIN repositories r FINAL ON r.insightsProjectId = i.id
49+
WHERE isNull(i.deletedAt)
50+
AND isNull(r.deletedAt)
51+
AND r.enabled = true
5052

5153
NODE segments_aggregates_with_ids_copy_software_value_deduplicated
5254
SQL >

0 commit comments

Comments
 (0)