Skip to content

Commit e7ec043

Browse files
gaspergromgaspergrom
committed
fix: missing nodes
Signed-off-by: Gašper Grom <gasper.grom@gmail.com>
1 parent 6f812c7 commit e7ec043

22 files changed

Lines changed: 0 additions & 820 deletions

‎services/libs/tinybird/pipes/health_score_active_contributors.pipe‎

Lines changed: 0 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -1,37 +1 @@
1-
NODE health_score_active_contributors_score
2-
DESCRIPTION >
3-
Returns activeContributors for previous quarter per project
4-
5-
SQL >
6-
%
7-
{% if defined(project) %}
8-
SELECT segmentId, COALESCE(uniq(memberId), 0) AS activeContributors
9-
FROM activityRelations_bucket_routing
10-
WHERE
11-
memberId != ''
12-
AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered)
13-
AND segmentId = (SELECT segmentId FROM segments_filtered)
14-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
15-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
16-
{% if defined(startDate) %}
17-
AND timestamp
18-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
19-
{% end %}
20-
{% if defined(endDate) %}
21-
AND timestamp
22-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
23-
{% end %}
24-
GROUP BY segmentId
25-
{% else %}
26-
SELECT segmentId, COALESCE(uniq(memberId), 0) AS activeContributors
27-
FROM activityRelations_deduplicated_cleaned_bucket_union
28-
WHERE
29-
memberId != ''
30-
AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered)
31-
AND timestamp >= toStartOfQuarter(now() - toIntervalQuarter(1))
32-
AND timestamp < toStartOfQuarter(now())
33-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
34-
GROUP BY segmentId
35-
{% end %}
36-
371
INCLUDE "../includes/health_score_active_contributors.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_active_contributors_score"

‎services/libs/tinybird/pipes/health_score_active_days.pipe‎

Lines changed: 0 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -1,30 +1 @@
1-
NODE health_score_active_days_score
2-
SQL >
3-
%
4-
{% if defined(project) %}
5-
SELECT segmentId, countDistinct(DATE(timestamp)) AS activeDaysCount
6-
FROM activityRelations_bucket_routing
7-
WHERE
8-
segmentId = (SELECT segmentId FROM segments_filtered)
9-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
10-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
11-
{% if defined(startDate) %}
12-
AND timestamp
13-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
14-
{% end %}
15-
{% if defined(endDate) %}
16-
AND timestamp
17-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
18-
{% end %}
19-
GROUP BY segmentId
20-
{% else %}
21-
SELECT segmentId, countDistinct(DATE(timestamp)) AS activeDaysCount
22-
FROM activityRelations_deduplicated_cleaned_bucket_union
23-
WHERE
24-
timestamp >= toStartOfDay(now() - toIntervalDay(365))
25-
AND timestamp < toStartOfDay(now())
26-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
27-
GROUP BY segmentId
28-
{% end %}
29-
301
INCLUDE "../includes/health_score_active_days.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_active_days_score"

‎services/libs/tinybird/pipes/health_score_contributions_outside_work_hours.pipe‎

Lines changed: 0 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -1,32 +1 @@
1-
NODE health_score_contributions_outside_work_hours_score
2-
SQL >
3-
%
4-
SELECT
5-
segmentId,
6-
round(
7-
(100. * countIf((weekday >= 6) OR (two_hours_block >= 18) OR (two_hours_block < 8)))
8-
/ count(id)
9-
) AS contributionsOutsideWorkHours
10-
FROM contributions_with_local_time_ds AS a
11-
WHERE
12-
1 = 1
13-
{% if defined(project) %}
14-
AND segmentId = (SELECT segmentId FROM segments_filtered)
15-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
16-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
17-
{% if defined(startDate) %}
18-
AND timestamp
19-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
20-
{% end %}
21-
{% if defined(endDate) %}
22-
AND timestamp
23-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
24-
{% end %}
25-
{% else %}
26-
AND timestamp >= toStartOfDay(now() - toIntervalDay(365))
27-
AND timestamp < toStartOfDay(now() + toIntervalDay(1))
28-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
29-
{% end %}
30-
GROUP BY segmentId
31-
321
INCLUDE "../includes/health_score_contributions_outside_work_hours.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_contributions_outside_work_hours_score"

‎services/libs/tinybird/pipes/health_score_contributor_dependency.pipe‎

Lines changed: 0 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -1,36 +1 @@
1-
NODE health_score_contributor_dependency_contribution_count
2-
SQL >
3-
%
4-
{% if defined(project) %}
5-
SELECT segmentId, memberId, count() AS contributionCount, MIN(timestamp), MAX(timestamp)
6-
FROM activityRelations_bucket_routing
7-
WHERE
8-
memberId != ''
9-
AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered)
10-
AND segmentId = (SELECT segmentId FROM segments_filtered)
11-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
12-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
13-
{% if defined(startDate) %}
14-
AND timestamp
15-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
16-
{% end %}
17-
{% if defined(endDate) %}
18-
AND timestamp
19-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
20-
{% end %}
21-
GROUP BY segmentId, memberId
22-
ORDER by contributionCount DESC
23-
{% else %}
24-
SELECT segmentId, memberId, count() AS contributionCount, MIN(timestamp), MAX(timestamp)
25-
FROM activityRelations_deduplicated_cleaned_bucket_union
26-
WHERE
27-
memberId != ''
28-
AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered)
29-
AND timestamp >= toStartOfDay(now() - INTERVAL 365 DAY)
30-
AND timestamp < toStartOfDay(now() + INTERVAL 1 DAY)
31-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
32-
GROUP BY segmentId, memberId
33-
ORDER by contributionCount DESC
34-
{% end %}
35-
361
INCLUDE "../includes/health_score_contributor_dependency.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_contributor_dependency_contribution_count"

‎services/libs/tinybird/pipes/health_score_forks.pipe‎

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -1,31 +1 @@
1-
NODE health_score_forks_score
2-
DESCRIPTION >
3-
Returns activeContributors for previous quarter per project
4-
5-
SQL >
6-
%
7-
{% if defined(project) %}
8-
SELECT segmentId, count() AS forks
9-
FROM activityRelations_bucket_routing
10-
WHERE
11-
type = 'fork'
12-
AND segmentId = (SELECT segmentId FROM segments_filtered)
13-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
14-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
15-
{% if defined(startDate) %}
16-
AND timestamp
17-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
18-
{% end %}
19-
{% if defined(endDate) %}
20-
AND timestamp
21-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
22-
{% end %}
23-
GROUP BY segmentId
24-
{% else %}
25-
SELECT segmentId, count() AS forks
26-
FROM activityRelations_deduplicated_cleaned_bucket_union
27-
WHERE type = 'fork' AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
28-
GROUP BY segmentId
29-
{% end %}
30-
311
INCLUDE "../includes/health_score_forks.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_forks_score"

‎services/libs/tinybird/pipes/health_score_issues_resolution.pipe‎

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -8,34 +8,4 @@ DESCRIPTION >
88
- `startDate`: Optional DateTime filter for issues opened after timestamp
99
- `endDate`: Optional DateTime filter for issues opened before timestamp
1010

11-
NODE health_score_issues_resolution_score
12-
SQL >
13-
%
14-
{% if defined(project) %}
15-
SELECT segmentId, round(avg(closedInSeconds) / (60 * 60 * 24)) AS issueResolution
16-
FROM issues_analyzed
17-
WHERE
18-
segmentId = (SELECT segmentId FROM segments_filtered)
19-
AND closedAt IS NOT NULL
20-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
21-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
22-
{% if defined(startDate) %}
23-
AND openedAt
24-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
25-
{% end %}
26-
{% if defined(endDate) %}
27-
AND openedAt < {{ DateTime(endDate, description="Filter before date", required=False) }}
28-
{% end %}
29-
GROUP BY segmentId
30-
{% else %}
31-
SELECT segmentId, round(avg(closedInSeconds) / (60 * 60 * 24)) AS issueResolution
32-
FROM issues_analyzed
33-
WHERE
34-
openedAt >= toStartOfDay(now()) - INTERVAL 365 DAY
35-
AND openedAt < toStartOfDay(now()) + INTERVAL 1 DAY
36-
AND closedAt IS NOT NULL
37-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
38-
GROUP BY segmentId
39-
{% end %}
40-
4111
INCLUDE "../includes/health_score_issues_resolution.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_issues_resolution_score"

‎services/libs/tinybird/pipes/health_score_merge_lead_time.pipe‎

Lines changed: 0 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -1,29 +1 @@
1-
NODE health_score_merge_lead_time_score
2-
DESCRIPTION >
3-
Returns activeContributors for previous quarter per project
4-
5-
SQL >
6-
%
7-
SELECT segmentId, round(avg(dateDiff('day', openedAt, mergedAt))) AS mergeLeadTime
8-
FROM pull_requests_analyzed
9-
WHERE
10-
1 = 1
11-
{% if defined(project) %}
12-
AND segmentId = (SELECT segmentId FROM segments_filtered)
13-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
14-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
15-
{% if defined(startDate) %}
16-
AND openedAt
17-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
18-
{% end %}
19-
{% if defined(endDate) %}
20-
AND openedAt < {{ DateTime(endDate, description="Filter before date", required=False) }}
21-
{% end %}
22-
{% else %}
23-
AND openedAt >= toStartOfDay(now() - toIntervalDay(365))
24-
AND openedAt < toStartOfDay(now() + toIntervalDay(1))
25-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
26-
{% end %}
27-
GROUP BY segmentId
28-
291
INCLUDE "../includes/health_score_merge_lead_time.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_merge_lead_time_score"

‎services/libs/tinybird/pipes/health_score_organization_dependency.pipe‎

Lines changed: 0 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -1,34 +1 @@
1-
NODE health_score_organization_dependency_contribution_count
2-
SQL >
3-
%
4-
{% if defined(project) %}
5-
SELECT segmentId, organizationId, count() AS contributionCount
6-
FROM activityRelations_bucket_routing
7-
WHERE
8-
organizationId != ''
9-
AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered)
10-
AND segmentId = (SELECT segmentId FROM segments_filtered)
11-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
12-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
13-
{% if defined(startDate) %}
14-
AND timestamp
15-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
16-
{% end %}
17-
{% if defined(endDate) %}
18-
AND timestamp
19-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
20-
{% end %}
21-
GROUP BY segmentId, organizationId
22-
{% else %}
23-
SELECT segmentId, organizationId, count() AS contributionCount
24-
FROM activityRelations_deduplicated_cleaned_bucket_union
25-
WHERE
26-
organizationId != ''
27-
AND (type, platform) IN (SELECT activityType, platform FROM activityTypes_filtered)
28-
AND timestamp >= toStartOfDay(now() - INTERVAL 365 DAY)
29-
AND timestamp < toStartOfDay(now() + INTERVAL 1 DAY)
30-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
31-
GROUP BY segmentId, organizationId
32-
{% end %}
33-
341
INCLUDE "../includes/health_score_organization_dependency.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_organization_dependency_contribution_count"

‎services/libs/tinybird/pipes/health_score_pull_requests.pipe‎

Lines changed: 0 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -1,43 +1 @@
1-
NODE health_score_pull_requests_score
2-
DESCRIPTION >
3-
Returns activeContributors for previous quarter per project
4-
5-
SQL >
6-
%
7-
{% if defined(project) %}
8-
SELECT segmentId, count() AS pullRequests
9-
FROM activityRelations_bucket_routing
10-
WHERE
11-
(
12-
type = 'pull_request-opened'
13-
OR type = 'merge_request-opened'
14-
OR type = 'changeset-created'
15-
)
16-
AND segmentId = (SELECT segmentId FROM segments_filtered)
17-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
18-
{% if defined(repos) %} AND channel IN (SELECT channel FROM repos_to_channels) {% end %}
19-
{% if defined(startDate) %}
20-
AND timestamp
21-
> {{ DateTime(startDate, description="Filter after date", required=False) }}
22-
{% end %}
23-
{% if defined(endDate) %}
24-
AND timestamp
25-
< {{ DateTime(endDate, description="Filter before date", required=False) }}
26-
{% end %}
27-
GROUP BY segmentId
28-
{% else %}
29-
SELECT segmentId, count() AS pullRequests
30-
FROM activityRelations_deduplicated_cleaned_bucket_union
31-
WHERE
32-
(
33-
type = 'pull_request-opened'
34-
OR type = 'merge_request-opened'
35-
OR type = 'changeset-created'
36-
)
37-
AND timestamp >= toStartOfDay(now() - toIntervalDay(365))
38-
AND timestamp < toStartOfDay(now() + toIntervalDay(1))
39-
AND channel NOT IN (SELECT channel FROM repos_to_channels_excluded)
40-
GROUP BY segmentId
41-
{% end %}
42-
431
INCLUDE "../includes/health_score_pull_requests.incl" "GROUP_COL=segmentId" "SOURCE_NODE=health_score_pull_requests_score"

0 commit comments

Comments
 (0)