From cf2c0ec7b33d8b9dcaf7723894006e47bbd0be37 Mon Sep 17 00:00:00 2001
From: whyour <imwhyour@gmail.com>
Date: Mon, 24 Aug 2026 18:27:53 +0800
Subject: [PATCH] test(ql3): tolerate initial postgres cron boundary

---
 .../test/postgres.integration.test.cjs        | 26 ++++++++++++++-----
 1 file changed, 20 insertions(+), 6 deletions(-)

diff --git a/packages/ql3-cluster-postgres/test/postgres.integration.test.cjs b/packages/ql3-cluster-postgres/test/postgres.integration.test.cjs
index b3eb6ffa..6a53fe3d 100644
--- a/packages/ql3-cluster-postgres/test/postgres.integration.test.cjs
+++ b/packages/ql3-cluster-postgres/test/postgres.integration.test.cjs
@@ -4868,13 +4868,27 @@ if (!migrationConnectionString) {
         5_000,
         nextMinute,
       );
-      assert.equal(initialize.disposition, 'initialize');
+      const initializationIds = {
+        runId: '019f7900-0000-7000-8000-000000000101',
+        attemptId: '019f7900-0000-7000-8000-000000000102',
+        createdEventId: '019f7900-0000-7000-8000-000000000103',
+        queuedEventId: '019f7900-0000-7000-8000-000000000104',
+      };
+      const initialization = await schedules.commitClusterScheduleDecision({
+        claim: initializeClaim,
+        decision: initialize,
+        ...(initialize.disposition === 'admit' ? initializationIds : {}),
+      });
       assert.deepEqual(
-        await schedules.commitClusterScheduleDecision({
-          claim: initializeClaim,
-          decision: initialize,
-        }),
-        { status: 'advanced', disposition: 'initialize' },
+        initialization,
+        initialize.disposition === 'admit'
+          ? {
+              status: 'admitted',
+              disposition: 'admit',
+              runId: initializationIds.runId,
+              attemptId: initializationIds.attemptId,
+            }
+          : { status: 'advanced', disposition: initialize.disposition },
       );
 
       const forcedDueResult = await database.pool.query(