From a82b7fb98b0f94d391712ad0fbb478a7cb9fdbe1 Mon Sep 17 00:00:00 2001 From: whyour Date: Sat, 22 Aug 2026 19:05:54 +0800 Subject: [PATCH] fix(test): use database clock for claim takeover --- .../test/postgres.integration.test.cjs | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/packages/ql3-cluster-control/test/postgres.integration.test.cjs b/packages/ql3-cluster-control/test/postgres.integration.test.cjs index ccc05e9b..5100e5ef 100644 --- a/packages/ql3-cluster-control/test/postgres.integration.test.cjs +++ b/packages/ql3-cluster-control/test/postgres.integration.test.cjs @@ -1014,9 +1014,14 @@ if (!migrationConnectionString || !runtimeConnectionString) { await runtimeA.close(); runtimeA = undefined; await migration.pool.query( - `UPDATE "ql3"."trigger_schedules" - SET updated_at_ms = updated_at_ms - 2, - claim_expires_at_ms = updated_at_ms - 1 + `WITH observation AS MATERIALIZED ( + SELECT floor(extract(epoch FROM clock_timestamp()) * 1000)::bigint + AS observed_at_ms + ) + UPDATE "ql3"."trigger_schedules" + SET updated_at_ms = observation.observed_at_ms - 2, + claim_expires_at_ms = observation.observed_at_ms - 1 + FROM observation WHERE project_id = 'default' AND trigger_id = $1`, [takeoverTrigger.triggerId], );