select RPO from db to report metrics

ydb-platform · Dec 17, 2024 · 2a4f9f1 · 2a4f9f1
1 parent 8f0a13c
commit 2a4f9f1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/watchers/schedule_watcher/schedule_watcher.go b/internal/watchers/schedule_watcher/schedule_watcher.go
@@ -46,10 +46,10 @@ func ScheduleWatcherAction(
 	ctx, cancel := context.WithTimeout(baseCtx, period)
 	defer cancel()
 
-	schedules, err := db.SelectBackupSchedules(
-		//WithRPOInfo
+	//TODO: add pagination or switch to Query.Client()
+	schedules, err := db.SelectBackupSchedulesWithRPOInfo(
 		ctx, queries.NewReadTableQuery(
-			queries.WithTableName("BackupSchedules"),
+			queries.WithRawQuery(queries.ListSchedulesQuery),
 			queries.WithQueryFilters(
 				queries.QueryFilter{
 					Field: "status",