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])