fix reten

perhamm · anton.voskresensky · web-flow · commit 3f9bef74189a · 2025-11-05T17:38:30.000+03:00
Co-authored-by: anton.voskresensky &lt;anton.voskresensky@flant.com&gt;
diff --git a/commands/retention.go b/commands/retention.go
@@ -90,6 +90,8 @@ func runRetention(cmd *cobra.Command, args []string) error {
 			continue
 		}
 
+		logger.Info(fmt.Sprintf("Valid snapshot found index=%s", idx.Index))
+
 		indicesToDelete = append(indicesToDelete, idx)
 	}
 
@@ -132,6 +134,10 @@ func runRetention(cmd *cobra.Command, args []string) error {
 		}
 
 		logger.Info(fmt.Sprintf("Updated utilization utilization=%d", avgUtil))
+
+		if float64(avgUtil) <= threshold {
+			break
+		}
 	}
 
 	logger.Info(fmt.Sprintf("Retention completed finalUtilization=%d", avgUtil))

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,8 @@ func runRetention(cmd *cobra.Command, args []string) error {`
`90`	`90`	`continue`
`91`	`91`	`}`
`92`	`92`
	`93`	`+ logger.Info(fmt.Sprintf("Valid snapshot found index=%s", idx.Index))`
	`94`	`+`
`93`	`95`	`indicesToDelete = append(indicesToDelete, idx)`
`94`	`96`	`}`
`95`	`97`
`@@ -132,6 +134,10 @@ func runRetention(cmd *cobra.Command, args []string) error {`
`132`	`134`	`}`
`133`	`135`
`134`	`136`	`logger.Info(fmt.Sprintf("Updated utilization utilization=%d", avgUtil))`
	`137`	`+`
	`138`	`+ if float64(avgUtil) <= threshold {`
	`139`	`+ break`
	`140`	`+ }`
`135`	`141`	`}`
`136`	`142`
`137`	`143`	`logger.Info(fmt.Sprintf("Retention completed finalUtilization=%d", avgUtil))`