i/Aether
1
0
Fork 0
mirror of https://github.com/fawney19/Aether.git synced 2026-09-09 04:30:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #641 from Kayphoon/codex/usage-cleanup-break-condition

Browse Source 
fix(usage): align cleanup loop break conditions with candidate row count
This commit is contained in:
fawney19
2026-06-17 11:04:55 +08:00
committed by GitHub
parent 34f0913ed0 6d1b818414
commit 6de0fe75a4
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/aether-data/src/repository/usage/postgres/cleanup.rs
+4 -4
View File
@@ -683,7 +683,7 @@ async fn cleanup_usage_raw_body_fields(
.rows_affected();
let cleaned = usize::try_from(cleaned).unwrap_or(usize::MAX);
total_cleaned += cleaned;
if cleaned == 0 || cleaned < batch_size {
if rows.len() < batch_size {
break;
}
}
@@ -736,7 +736,7 @@ async fn cleanup_usage_compressed_body_fields(
.map_err(postgres_error)?;
let cleaned = usize::try_from(cleaned).unwrap_or(usize::MAX);
total_cleaned += cleaned;
if cleaned == 0 || cleaned < batch_size {
if rows.len() < batch_size {
break;
}
}
@@ -1143,7 +1143,7 @@ async fn cleanup_usage_header_fields(
.map_err(postgres_error)?;
let cleaned = usize::try_from(cleaned).unwrap_or(usize::MAX);
total_cleaned += cleaned;
if cleaned == 0 || cleaned < batch_size {
if rows.len() < batch_size {
break;
}
}
@@ -1213,7 +1213,7 @@ async fn cleanup_usage_stale_body_fields(
.map_err(postgres_error)?;
let cleaned = usize::try_from(cleaned).unwrap_or(usize::MAX);
total_cleaned += cleaned;
if cleaned == 0 || cleaned < batch_size {
if rows.len() < batch_size {
break;
}
}