fix: sync explicit consumer QPK pin test contracts

Co-Authored-By: Codex <noreply@openai.com>

Author: Pigbibi

scripts/open_downstream_qpk_pin_prs.py

@@ -166,6 +166,43 @@ def update_drift_workflow_test_contract(
     return True
 
 
+def update_qpk_test_pin_contracts(
+    repo_dir: Path,
+    *,
+    qpk_sha: str,
+    previous_qpk_refs: set[str],
+) -> bool:
+    """Refresh explicit QPK SHA assertions in consumer test contracts only.
+
+    Some P1 pipelines assert their declared QPK revision in a test instead of
+    reading the declaration dynamically.  Those assertions are part of the
+    dependency surface, but must not leave a generated update red.  Restrict
+    replacement to test files that explicitly name QuantPlatformKit and to an
+    SHA that was already declared by the repository before this sync.
+    """
+    tests_dir = repo_dir / "tests"
+    if not tests_dir.is_dir():
+        return False
+
+    changed = False
+    previous = {
+        sha
+        for sha in previous_qpk_refs
+        if re.fullmatch(r"[a-f0-9]{40}", sha) and sha != qpk_sha
+    }
+    for path in sorted(tests_dir.rglob("test_*.py")):
+        original = path.read_text(encoding="utf-8")
+        if "QuantPlatformKit" not in original:
+            continue
+        updated = original
+        for prior_sha in sorted(previous):
+            updated = updated.replace(prior_sha, qpk_sha)
+        if updated != original:
+            path.write_text(updated, encoding="utf-8")
+            changed = True
+    return changed
+
+
 def update_strategy_dependency_pins(
     repo_dir: Path,
     strategy_heads: dict[str, str],
@@ -337,6 +374,11 @@ def update_repo(
         previous_qpk_refs=previous_qpk_refs,
     )
     if strategy_heads:
+        update_qpk_test_pin_contracts(
+            repo_dir,
+            qpk_sha=get_qpk_pin_sha(pin_file=qpk_pin),
+            previous_qpk_refs=previous_qpk_refs,
+        )
         update_strategy_dependency_pins(repo_dir, strategy_heads)
         update_qsl_strategy_requires(repo_dir, strategy_heads)
         update_qsl_metadata_test_contract(

tests/test_qpk_pin_consistency.py

@@ -22,6 +22,7 @@
     update_qsl_strategy_requires,
     update_qsl_compat_qpk_pin,
     update_drift_workflow_test_contract,
+    update_qpk_test_pin_contracts,
     update_qpk_revision_contract,
     update_strategy_dependency_pins,
 )
@@ -130,6 +131,29 @@ def test_detect_reusable_workflow_qpk_pin_drift(self) -> None:
         self.assertGreater(mismatches, 0)
         self.assertTrue(any(".github/workflows/drift-check.yml" in err for err in errors))
 
+    def test_update_qpk_test_pin_contracts_only_touches_explicit_contracts(self) -> None:
+        with tempfile.TemporaryDirectory() as tmp:
+            root = Path(tmp)
+            tests_dir = root / "tests"
+            tests_dir.mkdir()
+            contract = tests_dir / "test_qpk_contract.py"
+            contract.write_text(
+                f'EXPECTED = "{STALE}"\nassert "QuantPlatformKit"\n',
+                encoding="utf-8",
+            )
+            unrelated = tests_dir / "test_unrelated.py"
+            unrelated.write_text(f'EXPECTED = "{STALE}"\n', encoding="utf-8")
+
+            changed = update_qpk_test_pin_contracts(
+                root,
+                qpk_sha=TARGET,
+                previous_qpk_refs={STALE},
+            )
+
+            self.assertTrue(changed)
+            self.assertIn(TARGET, contract.read_text(encoding="utf-8"))
+            self.assertIn(STALE, unrelated.read_text(encoding="utf-8"))
+
     def test_override_must_match_pin(self) -> None:
         pyproject = """
 [tool.uv]