R14-TQ1-R3-R1 claim-local protected-placeholder recovery

core/pipeline_agent.py

@@ -5499,31 +5499,55 @@ Translate headings and terminology naturally. Preserve standard variable abbrevi
                 claim_sources={claim_id: source_claim}, keep_claim_markers=True,
             )
         except DeepSeekRequestError as error:
-            if not self._is_translation_unowned_numeric_error(error):
+            if str(error or '').startswith('Translation protected placeholder mismatch'):
+                logging.warning(
+                    'Translation claim-local protected-skeleton recovery: block=SP-P%s claim=%s error=%s; strict retry once.',
+                    block_id, claim_id, self._safe_source_error(error),
+                )
+                strict_prompt = system_prompt + (
+                    '\nSTRICT PROTECTED-SKELETON RECOVERY FOR ONE CLAIM. Re-translate only this one claim from the frozen marked English source. '
+                    'Preserve every SP-P, SP-C, and SP-T marker byte-for-byte and exactly once. Do not delete, duplicate, rename, reorder across claim ownership, translate, normalize, or invent any marker. '
+                    'Do not add, remove, merge, or reinterpret claims or factual content. Return only the marked translated claim.'
+                    + '\n<SEMANTIC_ANCHOR_MANIFEST>\n'
+                    + json.dumps({block_id: safe_manifest}, ensure_ascii=False)
+                    + '\n</SEMANTIC_ANCHOR_MANIFEST>'
+                )
+                strict_result = self.call_deepseek(
+                    strict_prompt, marked_source,
+                    max_tokens=max(1200, min(2600, self._count_tokens(marked_source) * 2 + 900)),
+                    temp=0.0, model_role='translation', thinking=False, allow_fallback=False,
+                )
+                strict_parsed = self._parse_marked_translation(strict_result, [block_id])
+                restored = self._restore_translation_tokens(
+                    strict_parsed[block_id], mapping, f'SP-P{block_id}', target_lang,
+                    claim_sources={claim_id: source_claim}, keep_claim_markers=True,
+                )
+            elif self._is_translation_unowned_numeric_error(error):
+                logging.warning(
+                    'Translation claim-local numeric recovery: block=SP-P%s claim=%s error=%s',
+                    block_id, claim_id, self._safe_source_error(error),
+                )
+                numeric_prompt = system_prompt + (
+                    '\nNUMERIC FACT RECOVERY FOR ONE CLAIM. Repair only this claim. Preserve every SP-P, SP-C, and SP-T marker byte-for-byte. '
+                    'Do not introduce any Arabic digit, percentage, sample size, scale point, model number, date number, or other numeric surface unless it is represented by an SP-T marker or is directly and unambiguously expressed by an English number-word, ordinal, fold expression, relational quantity, or month name in this source claim. '
+                    'If a lexical quantity is not protected by SP-T and you are uncertain, express it lexically in the target language rather than inventing an Arabic digit. '
+                    'Do not add, remove, merge, or reinterpret claims. Return only the marked translated claim.'
+                    + '\n<SEMANTIC_ANCHOR_MANIFEST>\n'
+                    + json.dumps({block_id: safe_manifest}, ensure_ascii=False)
+                    + '\n</SEMANTIC_ANCHOR_MANIFEST>'
+                )
+                retry_result = self.call_deepseek(
+                    numeric_prompt, marked_source,
+                    max_tokens=max(1200, min(2600, self._count_tokens(marked_source) * 2 + 900)),
+                    temp=0.0, model_role='translation', thinking=False, allow_fallback=False,
+                )
+                retry_parsed = self._parse_marked_translation(retry_result, [block_id])
+                restored = self._restore_translation_tokens(
+                    retry_parsed[block_id], mapping, f'SP-P{block_id}', target_lang,
+                    claim_sources={claim_id: source_claim}, keep_claim_markers=True,
+                )
+            else:
                 raise
-            logging.warning(
-                'Translation claim-local numeric recovery: block=SP-P%s claim=%s error=%s',
-                block_id, claim_id, self._safe_source_error(error),
-            )
-            numeric_prompt = system_prompt + (
-                '\nNUMERIC FACT RECOVERY FOR ONE CLAIM. Repair only this claim. Preserve every SP-P, SP-C, and SP-T marker byte-for-byte. '
-                'Do not introduce any Arabic digit, percentage, sample size, scale point, model number, date number, or other numeric surface unless it is represented by an SP-T marker or is directly and unambiguously expressed by an English number-word, ordinal, fold expression, relational quantity, or month name in this source claim. '
-                'If a lexical quantity is not protected by SP-T and you are uncertain, express it lexically in the target language rather than inventing an Arabic digit. '
-                'Do not add, remove, merge, or reinterpret claims. Return only the marked translated claim.'
-                + '\n<SEMANTIC_ANCHOR_MANIFEST>\n'
-                + json.dumps({block_id: safe_manifest}, ensure_ascii=False)
-                + '\n</SEMANTIC_ANCHOR_MANIFEST>'
-            )
-            retry_result = self.call_deepseek(
-                numeric_prompt, marked_source,
-                max_tokens=max(1200, min(2600, self._count_tokens(marked_source) * 2 + 900)),
-                temp=0.0, model_role='translation', thinking=False, allow_fallback=False,
-            )
-            retry_parsed = self._parse_marked_translation(retry_result, [block_id])
-            restored = self._restore_translation_tokens(
-                retry_parsed[block_id], mapping, f'SP-P{block_id}', target_lang,
-                claim_sources={claim_id: source_claim}, keep_claim_markers=True,
-            )
         clean = self._strip_translation_claim_markers(restored)
         self._validate_translation_block_protected(block_id, source_claim, clean, target_lang)
         _order, segments = self._parse_translation_claim_segments(restored, [claim_id])