Fix Aurora function

This commit is contained in:
Konstantin Wohlwend 2026-01-12 21:19:23 -08:00
parent 47b7feef6d
commit 92ca8af84b

View File

@ -201,7 +201,7 @@ async function waitForReplication(replicas: PrismaClient[], target: string, time
const [{ current_lsn }] = await (replica as any).$queryRaw<[{ current_lsn: bigint | null }]>`
SELECT current_read_lsn AS current_lsn
FROM aurora_replica_status()
WHERE server_id = aurora_server_id()
WHERE server_id = aurora_db_instance_identifier()
`;
return current_lsn === null || current_lsn >= targetBigInt;
};