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

恢复历史 backfill 兼容 live 账本

Browse Source
This commit is contained in:
MMEXA
2026-07-08 22:34:29 +08:00
parent f9c8ec41f4
commit 5c68ab896a
2 changed files with 60 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/aether-data/backfills/postgres/20260517012000_sync_legacy_enabled_active_flags.sql
+47
View File
@@ -0,0 +1,47 @@
DO $$
BEGIN
IF EXISTS (
SELECT 1
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'providers'
AND column_name = 'enabled'
) THEN
UPDATE public.providers
SET
is_active = enabled,
updated_at = NOW()
WHERE enabled IS NOT NULL
AND is_active IS DISTINCT FROM enabled;
END IF;
IF EXISTS (
SELECT 1
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'provider_endpoints'
AND column_name = 'enabled'
) THEN
UPDATE public.provider_endpoints
SET
is_active = enabled,
updated_at = NOW()
WHERE enabled IS NOT NULL
AND is_active IS DISTINCT FROM enabled;
END IF;
IF EXISTS (
SELECT 1
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'models'
AND column_name = 'enabled'
) THEN
UPDATE public.models
SET
is_active = enabled,
updated_at = NOW()
WHERE enabled IS NOT NULL
AND is_active IS DISTINCT FROM enabled;
END IF;
END $$;
crates/aether-data/src/lifecycle/backfill.rs
+13 -5
View File
@@ -312,7 +312,8 @@ mod tests {
20260422110000,
20260422120000,
20260504120000,
20260505120000
20260505120000,
20260517012000
]
);
}
@@ -328,7 +329,12 @@ mod tests {
.collect::<Vec<_>>();
assert_eq!(
versions,
vec![20260422120000, 20260504120000, 20260505120000]
vec![
20260422120000,
20260504120000,
20260505120000,
20260517012000
]
);
}
@@ -697,11 +703,12 @@ mod tests {
let pending_before = pending_backfills(&pool)
.await
.expect("pending backfills should load");
assert_eq!(pending_before.len(), 4);
assert_eq!(pending_before.len(), 5);
assert_eq!(pending_before[0].version, 20260422110000);
assert_eq!(pending_before[1].version, 20260422120000);
assert_eq!(pending_before[2].version, 20260504120000);
assert_eq!(pending_before[3].version, 20260505120000);
assert_eq!(pending_before[4].version, 20260517012000);
run_backfills(&pool)
.await
@@ -723,7 +730,8 @@ mod tests {
20260422110000,
20260422120000,
20260504120000,
20260505120000
20260505120000,
20260517012000
]
);
@@ -1385,6 +1393,6 @@ mod tests {
.fetch_one(&pool)
.await
.expect("backfill count should load");
assert_eq!(applied_count, 3);
assert_eq!(applied_count, 5);
}
}