Merge pull request #2801 from actiontech/2028-4

feat: get backup status and result
actiontech · Dec 5, 2024 · f0395ca · f0395ca
2 parents 02e3341 + a1a08d5
commit f0395ca
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/sqle/api/controller/v2/task.go b/sqle/api/controller/v2/task.go
@@ -153,6 +153,8 @@ func GetTaskSQLs(c echo.Context) error {
 			SQLType:                     taskSQL.SQLType.String,
 			BackupStrategy:              backupTaskMap.GetBackupStrategy(taskSQL.Id),
 			BackupStrategyTip:           backupTaskMap.GetBackupStrategyTip(taskSQL.Id),
+			BackupStatus:                backupTaskMap.GetBackupStatus(taskSQL.Id),
+			BackupResult:                backupTaskMap.GetBackupResult(taskSQL.Id),
 			AssociatedRollbackWorkflows: associatedRollbackWorkflowsMap[taskSQL.Id],
 		}
 		for i := range taskSQL.AuditResults {

diff --git a/sqle/server/backup.go b/sqle/server/backup.go
@@ -35,6 +35,20 @@ func (m backupTaskMap) GetBackupStrategy(sqlId uint) string {
 	return ""
 }
 
+func (m backupTaskMap) GetBackupStatus(sqlId uint) string {
+	if task, exist := m[sqlId]; exist {
+		return task.BackupStatus
+	}
+	return ""
+}
+
+func (m backupTaskMap) GetBackupResult(sqlId uint) string {
+	if task, exist := m[sqlId]; exist {
+		return task.BackupExecResult
+	}
+	return ""
+}
+
 func (m backupTaskMap) GetBackupStrategyTip(sqlId uint) string {
 	if task, exist := m[sqlId]; exist {
 		return task.BackupStrategyTip