From 0b5b4660e57c17a0f584973fd850234b171b6bdd Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Sat, 12 Sep 2026 13:29:05 +0000 Subject: [PATCH] fix: guard ledger outbox outcomes by lease Co-authored-by: genichin <4282227+genichin@users.noreply.github.com> --- trex_core/adapters/persistence/postgresql.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/trex_core/adapters/persistence/postgresql.py b/trex_core/adapters/persistence/postgresql.py index aa5b0f0..5864957 100644 --- a/trex_core/adapters/persistence/postgresql.py +++ b/trex_core/adapters/persistence/postgresql.py @@ -745,8 +745,7 @@ class PostgreSQLLedgerOutbox: ] where = "WHERE correlation_id=%s AND instance_key=%s " if expected_claim_expires_at is None: - where += "AND status=%s AND claim_owner IS NULL AND claim_expires_at IS NULL" - params.append(WorkItemStatus.COMPLETED.value) + where += "AND claim_owner IS NULL AND claim_expires_at IS NULL" else: where += "AND claim_owner=%s AND claim_expires_at=%s" params.extend([self._worker_id, expected_claim_expires_at])