Skip to content

Commit b1795fa

Browse files
authored
fix: downloads count for ai report (IN-1182) (#4228)
Signed-off-by: Joana Maia <jmaia@contractor.linuxfoundation.org>
1 parent b0599e8 commit b1795fa

1 file changed

Lines changed: 39 additions & 12 deletions

File tree

services/libs/tinybird/pipes/agentic_ai_projects_list_copy.pipe

Lines changed: 39 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ SQL >
1313
AND isNull (cr.deletedAt)
1414
AND isNull (r.deletedAt)
1515
AND r.enabled = true
16+
AND r.insightsProjectId != ''
1617

1718
NODE ai_projects
1819
SQL >
@@ -99,18 +100,44 @@ NODE ai_package_metrics
99100
SQL >
100101
SELECT
101102
insightsProjectId,
102-
argMax(downloadsCount, date) AS downloads,
103-
toInt64(argMax(downloadsCount, date)) - toInt64(
104-
argMaxIf(downloadsCount, date, date <= toDate(now() - INTERVAL 30 DAY))
105-
) AS downloads30d,
106-
argMax(dockerDownloadsCount, date) AS dockerPulls,
107-
toInt64(argMax(dockerDownloadsCount, date)) - toInt64(
108-
argMaxIf(dockerDownloadsCount, date, date <= toDate(now() - INTERVAL 30 DAY))
109-
) AS dockerPulls30d,
110-
max(dependentReposCount) AS dependentRepos,
111-
max(dependentPackagesCount) AS dependentPackages
112-
FROM packageDownloads FINAL
113-
WHERE insightsProjectId IN (SELECT DISTINCT insightsProjectId FROM ai_repos)
103+
sum(downloads) AS downloads,
104+
sum(downloads30d) AS downloads30d,
105+
sum(dockerPulls) AS dockerPulls,
106+
sum(dockerPulls30d) AS dockerPulls30d,
107+
max(dependentRepos) AS dependentRepos,
108+
max(dependentPackages) AS dependentPackages
109+
FROM
110+
(
111+
SELECT
112+
insightsProjectId,
113+
argMax(downloadsCount, date) AS downloads,
114+
toInt64(argMax(downloadsCount, date)) - toInt64(
115+
argMaxIf(downloadsCount, date, date <= toDate(now() - INTERVAL 30 DAY))
116+
) AS downloads30d,
117+
argMax(dockerDownloadsCount, date) AS dockerPulls,
118+
toInt64(argMax(dockerDownloadsCount, date)) - toInt64(
119+
argMaxIf(dockerDownloadsCount, date, date <= toDate(now() - INTERVAL 30 DAY))
120+
) AS dockerPulls30d,
121+
max(dependentReposCount) AS dependentRepos,
122+
max(dependentPackagesCount) AS dependentPackages
123+
FROM
124+
(
125+
SELECT
126+
insightsProjectId,
127+
date,
128+
ecosystem,
129+
repo,
130+
name,
131+
argMax(downloadsCount, updatedAt) AS downloadsCount,
132+
argMax(dockerDownloadsCount, updatedAt) AS dockerDownloadsCount,
133+
argMax(dependentReposCount, updatedAt) AS dependentReposCount,
134+
argMax(dependentPackagesCount, updatedAt) AS dependentPackagesCount
135+
FROM packageDownloads
136+
WHERE insightsProjectId IN (SELECT DISTINCT insightsProjectId FROM ai_repos)
137+
GROUP BY insightsProjectId, date, ecosystem, repo, name
138+
)
139+
GROUP BY insightsProjectId, ecosystem, repo, name
140+
)
114141
GROUP BY insightsProjectId
115142

116143
NODE pr_metrics

0 commit comments

Comments
 (0)