V10.528 輕量化過期 identity 救援預覽

tests/test_competitor_match_attempts_persistence.py

@@ -113,6 +113,14 @@ def test_competitor_feeder_persists_all_match_attempt_outcomes():
     assert "read_only_no_crawl_no_llm_no_db_write" in source
     assert "run_retryable_candidate_revalidation" in source
     assert "run_expired_identity_search_recovery" in source
+    recovery_source = source.split("def _fetch_expired_identity_recovery_skus", 1)[1].split(
+        "def _fetch_expired_identity_skus", 1
+    )[0]
+    assert "expired_competitor AS" in recovery_source
+    assert "JOIN LATERAL" in recovery_source
+    assert "ORDER BY pr.timestamp DESC, pr.id DESC" in recovery_source
+    assert "ROW_NUMBER() OVER (PARTITION BY p.id" not in recovery_source
+    assert "candidate_limit" in recovery_source
     retryable_source = source.split("def _fetch_retryable_candidate_skus", 1)[1].split(
         "def _fetch_expired_identity_skus", 1
     )[0]