You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by ly...@apache.org on 2024/08/07 06:47:45 UTC
(incubator-devlake) 01/01: fix(dora): fix count errors
This is an automated email from the ASF dual-hosted git repository.
lynwee pushed a commit to branch dev-2
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
commit 5e8ef6f9e8ca47184e5608093be00e5ec8a019e6
Author: d4x1 <15...@qq.com>
AuthorDate: Wed Aug 7 14:47:32 2024 +0800
fix(dora): fix count errors
---
backend/plugins/dora/tasks/incident_deploy_connector.go | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/backend/plugins/dora/tasks/incident_deploy_connector.go b/backend/plugins/dora/tasks/incident_deploy_connector.go
index cc7e97aec..bf80675ae 100644
--- a/backend/plugins/dora/tasks/incident_deploy_connector.go
+++ b/backend/plugins/dora/tasks/incident_deploy_connector.go
@@ -63,7 +63,12 @@ func ConnectIncidentToDeployment(taskCtx plugin.SubTaskContext) errors.Error {
dal.Where("pm.project_name = ?", data.Options.ProjectName),
}
- count, err := db.Count(clauses...)
+ count, err := db.Count(
+ dal.Select(`i.*`),
+ dal.From(`incidents i`),
+ dal.Join(`left join project_mapping pm on pm.row_id = i.scope_id and pm.table = i.table`),
+ dal.Where("pm.project_name = ?", data.Options.ProjectName),
+ )
if err != nil {
logger.Error(err, "count incidents")
} else {