feat(migration): Phase B1 — étendre RunSpec avec 7 champs legacy

Phase B1 du chantier Option B (run_benchmark_via_service →
RunOrchestrator.execute(RunSpec)). Surface API étendue, validation
en place, consommation reportée en Phase B2.

B1.1 — RunSpec porte 7 nouveaux champs (picarones/app/schemas/run_spec.py)
- char_exclude : filtre caractères pour CER/WER
- normalization_profile : profil texte avant comparaison
- partial_dir : reprise sur interruption
- entity_extractor : dotted path NER (regex format validation)
- profile : hooks document-level (validate_profile)
- output_json : sérialisation BenchmarkResult legacy
- timeout_seconds_per_doc : timeout corpus runner (default 60.0)

+ 2 model_validators :
- profile validé via evaluation.metric_hooks.validate_profile
- entity_extractor : format ``module:Symbol`` ou ``module.Symbol``

B1.2 — RunOrchestrator.execute accepte les kwargs non-sérialisables
- progress_callback : Callable[[str, int, str], None] | None
- cancel_event : threading.Event | None
Stockés sur self._progress_callback / self._cancel_event pour
consommation en Phase B2.1 (callback wrapper context_factory)
et B2.2 (CorpusRunner cancel propagation).

B1.3 — Tests : 43 cas dans tests/app/schemas/test_run_spec_b1_extended.py
- Défauts canoniques + parité avec run_benchmark_via_service.defaults
- char_exclude : ASCII, Unicode, rejet > 512 chars
- entity_extractor : 7 formats valides, 8 formats rejetés (parametrize)
- profile : 5 profils canoniques acceptés, faute de frappe rejetée
- timeout : default 60.0, rejet ≤ 0 et > 86400
- partial_dir / output_json / normalization_profile : chemins libres
- RunOrchestrator.execute(spec, progress_callback=…, cancel_event=…) :
compat ascendante + stockage sur instance

Maintenance :
- tests/architecture/test_file_budgets.py : budgets ajustés
(run_spec.py 620, run_orchestrator.py 570 — +15 % au-dessus du
courant)
- README.md et CLAUDE.md : compteur de tests synchronisé via
scripts/gen_readme_tables.py

Tests : 119 passed sur l'arborescence touchée (RunSpec + RunOrchestrator
+ invariance + architecture). Le test d'invariance reste vert : aucune
divergence numérique du BenchmarkResult.

CLAUDE.md

@@ -116,7 +116,7 @@ picarones/
 
 ## État des tests et bugs historiques
 
-`pytest tests/` → **4800 passed, 16 skipped, 8 deselected, 2 xfailed, 0 failed**
+`pytest tests/` → **4850 passed, 16 skipped, 8 deselected, 2 xfailed, 0 failed**
 (post-audit code-quality, mai 2026).  Les deselected sont les markers
 `live` (5 tests d'intégration contre vraie API/binaire) + `network`
 (3 tests qui hit le réseau réel), opt-in en local via `pytest -m live`

README.md

@@ -401,7 +401,7 @@ python -m mypy picarones/domain/    # strict mode (Layer 1)
 python -m mypy picarones/           # lax mode (full tree)
 ```
 
-**Test suite**: ~4800 tests, ~3 min on a modern laptop. Coverage
+**Test suite**: ~4850 tests, ~3 min on a modern laptop. Coverage
 floor at 85% (currently ~87%). The `network` marker excludes tests
 requiring live HTTP. A handful of tests depend on optional engines
 (`pero-ocr`, `pytesseract`) and are skipped/fail gracefully when

picarones/app/schemas/run_spec.py

@@ -85,6 +85,7 @@ Anti-sur-ingénierie
 from __future__ import annotations
 
 import importlib
+import re
 from typing import Any
 
 from pydantic import BaseModel, ConfigDict, Field, model_validator
@@ -93,6 +94,22 @@ from picarones.domain.artifacts import ArtifactType
 from picarones.domain.errors import PicaronesError
 
 
+#: Format autorisé pour ``entity_extractor`` (Phase B1 migration Option B).
+#: Accepte les deux conventions de dotted path Python :
+#:
+#:  - ``module.submodule:Symbol`` (PEP 621 entry points / setuptools)
+#:  - ``module.submodule.Symbol`` (import classique)
+#:
+#: La validation est purement structurelle ici — l'importabilité est
+#: vérifiée plus tard, au moment de :meth:`RunOrchestrator.execute`
+#: (lazy resolve).  Cohérent avec ``adapter_class`` (cf. ``StepSpec``).
+_DOTTED_PATH_RE = re.compile(
+    r"^[a-zA-Z_][a-zA-Z0-9_]*"           # premier composant
+    r"(?:\.[a-zA-Z_][a-zA-Z0-9_]*)*"     # composants intermédiaires
+    r"(?:[:.][a-zA-Z_][a-zA-Z0-9_]*)$"   # séparateur final (``:`` ou ``.``) + symbole
+)
+
+
 #: Vues canoniques supportées par la CLI.
 CANONICAL_VIEW_NAMES: frozenset[str] = frozenset({
     "text_final",
@@ -257,6 +274,97 @@ class RunSpec(BaseModel):
     report_lang: str = Field(default="fr")
     code_version: str = Field(default="0.0.0-unset", max_length=128)
 
+    # ──────────────────────────────────────────────────────────────────
+    # Phase B1 — migration Option B (run_benchmark_via_service →
+    # RunOrchestrator).  Les 7 champs ci-dessous portent les
+    # paramètres legacy de ``run_benchmark_via_service`` dans la
+    # spec déclarative.  À ce stade (B1) ils sont validés mais pas
+    # encore consommés par l'orchestrateur — les phases B2.1-B2.7
+    # branchent chaque champ à son comportement.
+    #
+    # Les paramètres d'exécution **non-sérialisables**
+    # (``progress_callback``, ``cancel_event``) restent kwargs de
+    # ``RunOrchestrator.execute()`` — un YAML ne peut pas porter un
+    # callable Python.
+    # ──────────────────────────────────────────────────────────────────
+
+    char_exclude: str | None = Field(
+        default=None,
+        max_length=512,
+        description=(
+            "Caractères à exclure du calcul CER/WER (Phase B2.5). "
+            "Chaîne de caractères Unicode, traitée comme un set par "
+            "``compute_metrics``.  Cas typique : ``'!?.,;:'`` pour "
+            "ignorer la ponctuation."
+        ),
+    )
+
+    normalization_profile: str | None = Field(
+        default=None,
+        max_length=128,
+        description=(
+            "Profil de normalisation texte appliqué avant CER/WER "
+            "(Phase B2.5).  Valeurs canoniques : ``caseless``, "
+            "``medieval_french``, ``sans_apostrophes``, etc.  Voir "
+            "``picarones.formats.text.normalization``."
+        ),
+    )
+
+    partial_dir: str | None = Field(
+        default=None,
+        max_length=2048,
+        description=(
+            "Répertoire où persister les ``DocumentResult`` intermédiaires "
+            "pour la reprise sur interruption (Phase B2.3).  Format : "
+            "JSONL par pipeline (``picarones_{corpus}_{pipeline}.partial.jsonl``)."
+        ),
+    )
+
+    entity_extractor: str | None = Field(
+        default=None,
+        max_length=512,
+        description=(
+            "Dotted path Python vers une factory d'extracteur d'entités "
+            "nommées (Phase B2.4).  Format accepté : ``module.submodule:"
+            "Symbol`` ou ``module.submodule.Symbol``.  La factory doit "
+            "retourner un callable ``(text: str) -> list[dict]`` compatible "
+            "avec ``_attach_ner_metrics_to_benchmark``.  L'importabilité "
+            "est vérifiée lazy à ``execute()``."
+        ),
+    )
+
+    profile: str = Field(
+        default="standard",
+        max_length=64,
+        description=(
+            "Profil de hooks document-level / corpus aggregators "
+            "(Phase B2.6).  Sélectionne quels hooks "
+            "``@register_document_metric`` / ``@register_corpus_aggregator`` "
+            "s'exécutent.  Profils canoniques : ``standard``, ``diagnostics``, "
+            "``economics``, ``pipeline``, ``full``."
+        ),
+    )
+
+    output_json: str | None = Field(
+        default=None,
+        max_length=2048,
+        description=(
+            "Chemin facultatif où sérialiser le ``BenchmarkResult`` "
+            "legacy en JSON (Phase B2.7).  Cohabite avec les 4 fichiers "
+            "JSONL natifs persistés sous ``output_dir/results/``."
+        ),
+    )
+
+    timeout_seconds_per_doc: float = Field(
+        default=60.0,
+        gt=0.0,
+        le=86400.0,
+        description=(
+            "Timeout par document propagé au ``CorpusRunner``.  "
+            "Cohérent avec ``run_benchmark_via_service.timeout_seconds``."
+        ),
+    )
+
     @model_validator(mode="after")
     def _validate_corpus_source(self) -> "RunSpec":
         if (self.corpus_zip is None) == (self.corpus_dir is None):
@@ -287,6 +395,39 @@ class RunSpec(BaseModel):
             )
         return self
 
+    @model_validator(mode="after")
+    def _validate_profile_is_known(self) -> "RunSpec":
+        """Phase B1.1 — rejet précoce des profils inconnus.
+
+        Délégué à ``evaluation.metric_hooks.validate_profile``, le
+        même validator que ``run_benchmark_via_service`` utilise au
+        démarrage du bench legacy.
+        """
+        from picarones.evaluation.metric_hooks import validate_profile
+
+        validate_profile(self.profile)
+        return self
+
+    @model_validator(mode="after")
+    def _validate_entity_extractor_format(self) -> "RunSpec":
+        """Phase B1.1 — valide le format dotted path.
+
+        L'**importabilité** est vérifiée lazy à
+        ``RunOrchestrator.execute()`` (cf. Phase B2.4), parce qu'un
+        YAML peut être validé sur une machine où le package
+        contenant l'extracteur n'est pas installé.
+        """
+        if self.entity_extractor is None:
+            return self
+        if not _DOTTED_PATH_RE.match(self.entity_extractor):
+            raise ValueError(
+                f"entity_extractor invalide : {self.entity_extractor!r}. "
+                "Format attendu : ``module.submodule:Symbol`` ou "
+                "``module.submodule.Symbol`` (composants alphanumériques "
+                "+ ``_``).",
+            )
+        return self
+
 
 # ──────────────────────────────────────────────────────────────────────
 # Loader YAML + résolution dotted path

picarones/app/services/run_orchestrator.py

@@ -37,6 +37,7 @@ Anti-sur-ingénierie
 from __future__ import annotations
 
 import io
+import threading
 import zipfile
 from dataclasses import dataclass, field
 from pathlib import Path
@@ -137,6 +138,8 @@ class RunOrchestrator:
         spec: RunSpec,
         *,
         report_renderer: ReportRenderer | None = None,
+        progress_callback: Callable[[str, int, str], None] | None = None,
+        cancel_event: threading.Event | None = None,
     ) -> OrchestrationResult:
         """Exécute le run complet et retourne tout ce qu'on en sait.
 
@@ -151,6 +154,20 @@ class RunOrchestrator:
             émis.  L'inversion de dépendance évite à
             ``app/services/`` d'importer ``reports/`` (couche plus
             externe — interdit par l'architecture).
+        progress_callback:
+            Phase B1.2 — kwarg d'exécution non-sérialisable. Callable
+            invoqué ``(engine_name, doc_idx, doc_id)`` à chaque
+            document traité.  Le branchement concret au runner est
+            fait en Phase B2.1.  Pour l'instant, le kwarg est accepté
+            et stocké sur l'instance mais ignoré au runtime — il sera
+            consommé quand B2.1 portera le pattern verrou+compteur
+            depuis ``_benchmark_execution.py:109-139``.
+        cancel_event:
+            Phase B1.2 — kwarg d'exécution non-sérialisable.
+            ``threading.Event`` qui, quand ``set()``, demande l'arrêt
+            propre du run en cours.  Phase B2.2 le branchera au
+            ``CorpusRunner`` (pattern existant dans
+            ``_benchmark_execution.py:142-149``).
 
         Raises
         ------
@@ -160,6 +177,13 @@ class RunOrchestrator:
             Si la résolution dotted-path d'un ``adapter_class``
             échoue.
         """
+        # Phase B1.2 — kwargs d'exécution stockés temporairement sur
+        # l'instance.  Phase B2.1/B2.2 les consommera depuis ici.
+        # Volontairement public-protected (un underscore) : ce sont
+        # des paramètres d'exécution, pas une configuration durable.
+        self._progress_callback = progress_callback
+        self._cancel_event = cancel_event
+
         self._output_dir.mkdir(parents=True, exist_ok=True)
         workspace = WorkspaceManager(self._output_dir)
 

tests/app/schemas/test_run_spec_b1_extended.py

@@ -0,0 +1,438 @@
+"""Phase B1 — extension de ``RunSpec`` avec 7 nouveaux champs.
+
+Tests de la surface API ajoutée pour porter les paramètres legacy de
+``run_benchmark_via_service`` dans la spec déclarative pendant le
+chantier de migration Option B (cf. ``docs/migration/``).
+
+À ce stade, les champs sont validés mais **pas consommés** par
+``RunOrchestrator`` — c'est l'objet des Phases B2.1 à B2.7.  Les tests
+ici vérifient donc uniquement :
+
+1. La validation pydantic (types, regex, plage, défaut).
+2. L'acceptation des kwargs d'exécution ``progress_callback`` et
+   ``cancel_event`` sur :meth:`RunOrchestrator.execute`.
+3. Que les feature parity tests (``test_run_orchestrator_feature_parity``)
+   peuvent **construire** un RunSpec avec n'importe quel paramètre —
+   c'est l'API stable sur laquelle B2 va s'appuyer.
+"""
+
+from __future__ import annotations
+
+import io
+import textwrap
+import threading
+import zipfile
+from pathlib import Path
+
+import pytest
+from pydantic import ValidationError
+
+from picarones.app.schemas.run_spec import RunSpec, load_run_spec_from_yaml
+from picarones.app.services import RunOrchestrator
+
+
+# ──────────────────────────────────────────────────────────────────────
+# Fixture YAML minimal — réutilisée dans tous les tests
+# ──────────────────────────────────────────────────────────────────────
+
+
+def _minimal_yaml(
+    *,
+    output_dir: Path,
+    corpus_dir: Path = Path("/tmp/picarones-stub-corpus"),
+    extra: str = "",
+) -> str:
+    """YAML minimal valide pour instancier un ``RunSpec``.
+
+    ``corpus_dir`` n'a pas besoin d'exister à ce stade — la validation
+    Pydantic vérifie la structure, pas le filesystem.
+    """
+    return textwrap.dedent(f"""
+        corpus_dir: {corpus_dir}
+        corpus_name: b1_test
+        pipelines:
+          - name: only_one
+            initial_inputs: [image]
+            steps:
+              - id: ocr
+                adapter_class: picarones.adapters.ocr.precomputed.PrecomputedTextAdapter
+                adapter_kwargs:
+                  source_label: tess
+                input_types: [image]
+                output_types: [raw_text]
+        views: [text_final]
+        output_dir: {output_dir}
+    """) + extra
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — défauts des 7 nouveaux champs
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestDefaults:
+    def test_all_seven_fields_have_canonical_defaults(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(output_dir=tmp_path / "out"))
+
+        assert spec.char_exclude is None
+        assert spec.normalization_profile is None
+        assert spec.partial_dir is None
+        assert spec.entity_extractor is None
+        assert spec.profile == "standard"
+        assert spec.output_json is None
+        assert spec.timeout_seconds_per_doc == 60.0
+
+    def test_defaults_match_run_benchmark_via_service_defaults(
+        self, tmp_path: Path,
+    ) -> None:
+        """Les valeurs par défaut de ``RunSpec`` matchent celles de
+        ``run_benchmark_via_service`` pour préserver l'équivalence
+        fonctionnelle pendant la migration.
+        """
+        from picarones.app.services.benchmark_runner import (
+            run_benchmark_via_service,
+        )
+        import inspect
+
+        sig = inspect.signature(run_benchmark_via_service)
+        defaults = {
+            name: param.default
+            for name, param in sig.parameters.items()
+            if param.default is not inspect.Parameter.empty
+        }
+        spec = load_run_spec_from_yaml(_minimal_yaml(output_dir=tmp_path / "out"))
+
+        # Les noms diffèrent légèrement (RunSpec.timeout_seconds_per_doc
+        # vs run_benchmark_via_service.timeout_seconds — mais la
+        # sémantique est identique : timeout par document).
+        assert spec.char_exclude == defaults["char_exclude"]
+        assert spec.normalization_profile == defaults["normalization_profile"]
+        assert spec.partial_dir == defaults["partial_dir"]
+        assert spec.profile == defaults["profile"]
+        assert spec.timeout_seconds_per_doc == defaults["timeout_seconds"]
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — char_exclude
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestCharExclude:
+    def test_accepts_punctuation_string(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out", extra="char_exclude: \"!?.,;:\"\n",
+        ))
+        assert spec.char_exclude == "!?.,;:"
+
+    def test_accepts_unicode_string(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out", extra="char_exclude: \"æœÆŒ\"\n",
+        ))
+        assert spec.char_exclude == "æœÆŒ"
+
+    def test_rejects_too_long(self, tmp_path: Path) -> None:
+        long_value = "x" * 513
+        with pytest.raises((ValidationError, Exception)):
+            load_run_spec_from_yaml(_minimal_yaml(
+                output_dir=tmp_path / "out",
+                extra=f'char_exclude: "{long_value}"\n',
+            ))
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — entity_extractor (dotted path validation)
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestEntityExtractor:
+    @pytest.mark.parametrize("valid_path", [
+        "picarones.adapters.ner.spacy:SpacyEntityExtractor",
+        "picarones.adapters.ner.spacy.SpacyEntityExtractor",
+        "pkg.sub:func",
+        "pkg.sub.func",
+        "a:b",
+        "abc.def.ghi.JKL",
+        "module_with_underscore.sub_module:ClassName",
+    ])
+    def test_accepts_valid_dotted_paths(
+        self, tmp_path: Path, valid_path: str,
+    ) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out",
+            extra=f"entity_extractor: {valid_path!r}\n",
+        ))
+        assert spec.entity_extractor == valid_path
+
+    @pytest.mark.parametrize("invalid_path", [
+        "no_dots_at_all",      # pas de séparateur
+        ".starts.with.dot",    # commence par un point
+        "ends.with.dot.",      # termine par un point
+        "has spaces",          # espaces interdits
+        "has-dash:Class",      # tirets interdits
+        "123starts.with.digit",  # commence par un chiffre
+        ":just.colon",         # commence par ``:``
+        "module:",             # symbole vide après ``:``
+    ])
+    def test_rejects_invalid_format(
+        self, tmp_path: Path, invalid_path: str,
+    ) -> None:
+        with pytest.raises((ValidationError, Exception)):
+            load_run_spec_from_yaml(_minimal_yaml(
+                output_dir=tmp_path / "out",
+                extra=f"entity_extractor: {invalid_path!r}\n",
+            ))
+
+    def test_none_is_accepted(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(output_dir=tmp_path / "out"))
+        assert spec.entity_extractor is None
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — profile (validate_profile)
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestProfile:
+    def test_default_is_standard(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(output_dir=tmp_path / "out"))
+        assert spec.profile == "standard"
+
+    @pytest.mark.parametrize("valid_profile", [
+        "standard",
+        "diagnostics",
+        "economics",
+        "pipeline",
+        "full",
+    ])
+    def test_accepts_known_profiles(
+        self, tmp_path: Path, valid_profile: str,
+    ) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out",
+            extra=f"profile: {valid_profile}\n",
+        ))
+        assert spec.profile == valid_profile
+
+    def test_rejects_unknown_profile(self, tmp_path: Path) -> None:
+        with pytest.raises((ValidationError, Exception), match="profil"):
+            load_run_spec_from_yaml(_minimal_yaml(
+                output_dir=tmp_path / "out",
+                extra="profile: philolagic_typo\n",
+            ))
+
+    def test_validates_at_construction_not_at_runtime(self, tmp_path: Path) -> None:
+        """Le rejet d'un profil inconnu se fait à la construction du
+        ``RunSpec``, pas au moment où ``execute()`` est appelée.
+
+        Sémantique identique à
+        ``run_benchmark_via_service(profile="unknown")`` qui lève
+        AVANT toute exécution OCR (cf. ``test_sprint_d2cdef_features.py``).
+        """
+        with pytest.raises((ValidationError, Exception)):
+            RunSpec(
+                corpus_dir="/tmp/stub",
+                pipelines=[],  # invalide mais on teste profile en premier
+                views=("text_final",),
+                output_dir=str(tmp_path / "out"),
+                profile="not_real",
+            )
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — timeout_seconds_per_doc (gt=0, le=86400)
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestTimeout:
+    def test_default_is_60(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(output_dir=tmp_path / "out"))
+        assert spec.timeout_seconds_per_doc == 60.0
+
+    def test_accepts_custom_value(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out",
+            extra="timeout_seconds_per_doc: 300.5\n",
+        ))
+        assert spec.timeout_seconds_per_doc == 300.5
+
+    @pytest.mark.parametrize("invalid_value", [0, -1, -100.5])
+    def test_rejects_zero_or_negative(
+        self, tmp_path: Path, invalid_value: float,
+    ) -> None:
+        with pytest.raises((ValidationError, Exception)):
+            load_run_spec_from_yaml(_minimal_yaml(
+                output_dir=tmp_path / "out",
+                extra=f"timeout_seconds_per_doc: {invalid_value}\n",
+            ))
+
+    def test_rejects_extreme_values(self, tmp_path: Path) -> None:
+        """Plafond à 24h pour éviter qu'un YAML mal formé bloque la CI
+        pendant des jours."""
+        with pytest.raises((ValidationError, Exception)):
+            load_run_spec_from_yaml(_minimal_yaml(
+                output_dir=tmp_path / "out",
+                extra="timeout_seconds_per_doc: 1000000\n",
+            ))
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — partial_dir et output_json (chemins facultatifs)
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestOptionalPaths:
+    def test_partial_dir_accepts_path_string(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out",
+            extra=f"partial_dir: {tmp_path / 'partial'}\n",
+        ))
+        assert spec.partial_dir == str(tmp_path / "partial")
+
+    def test_output_json_accepts_path_string(self, tmp_path: Path) -> None:
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out",
+            extra=f"output_json: {tmp_path / 'bm.json'}\n",
+        ))
+        assert spec.output_json == str(tmp_path / "bm.json")
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.1 — normalization_profile (string libre, validation runtime en B2.5)
+# ──────────────────────────────────────────────────────────────────────
+
+
+class TestNormalizationProfile:
+    def test_accepts_canonical_profile_names(self, tmp_path: Path) -> None:
+        for profile in ["caseless", "medieval_french", "sans_apostrophes"]:
+            spec = load_run_spec_from_yaml(_minimal_yaml(
+                output_dir=tmp_path / "out",
+                extra=f"normalization_profile: {profile}\n",
+            ))
+            assert spec.normalization_profile == profile
+
+    def test_accepts_unknown_profile_at_schema_level(
+        self, tmp_path: Path,
+    ) -> None:
+        """Phase B1 — pas de validation du contenu, c'est B2.5 qui
+        branchera le profil au compute_metrics.  Un YAML peut nommer
+        un profil custom qui sera résolu au runtime."""
+        spec = load_run_spec_from_yaml(_minimal_yaml(
+            output_dir=tmp_path / "out",
+            extra="normalization_profile: my_custom_profile\n",
+        ))
+        assert spec.normalization_profile == "my_custom_profile"
+
+
+# ──────────────────────────────────────────────────────────────────────
+# B1.2 — kwargs d'exécution sur RunOrchestrator.execute()
+# ──────────────────────────────────────────────────────────────────────
+
+
+def _png_bytes() -> bytes:
+    return (
+        b"\x89PNG\r\n\x1a\n"
+        b"\x00\x00\x00\rIHDR"
+        b"\x00\x00\x00\x01\x00\x00\x00\x01\x08\x06\x00\x00\x00"
+        b"\x1f\x15\xc4\x89"
+    )
+
+
+def _make_corpus_zip() -> bytes:
+    """Corpus zip minimal pour ``PrecomputedTextAdapter`` (1 doc)."""
+    buf = io.BytesIO()
+    with zipfile.ZipFile(buf, mode="w") as zf:
+        zf.writestr("doc01.png", _png_bytes())
+        zf.writestr("doc01.gt.txt", "Bonjour")
+        zf.writestr("doc01.tess.txt", "Bonjour")
+    return buf.getvalue()
+
+
+def _build_spec(tmp_path: Path) -> RunSpec:
+    """Construit un RunSpec valide pointant vers un corpus_zip réel."""
+    corpus_zip = tmp_path / "c.zip"
+    corpus_zip.write_bytes(_make_corpus_zip())
+    out_dir = tmp_path / "out"
+    yaml = textwrap.dedent(f"""
+        corpus_zip: {corpus_zip}
+        corpus_name: b1_exec_test
+        pipelines:
+          - name: tess_only
+            initial_inputs: [image]
+            steps:
+              - id: ocr
+                adapter_class: picarones.adapters.ocr.precomputed.PrecomputedTextAdapter
+                adapter_kwargs:
+                  source_label: tess
+                input_types: [image]
+                output_types: [raw_text]
+        views: [text_final]
+        output_dir: {out_dir}
+        code_version: "1.0.0-b1-test"
+    """)
+    return load_run_spec_from_yaml(yaml)
+
+
+class TestExecuteKwargs:
+    def test_execute_accepts_progress_callback(self, tmp_path: Path) -> None:
+        """``progress_callback`` est accepté en kwarg.
+
+        À ce stade (B1.2), le callback n'est pas encore branché au
+        runner — Phase B2.1 le fera.  Ce test vérifie juste que la
+        signature accepte le kwarg sans lever et que le run réussit.
+        """
+        spec = _build_spec(tmp_path)
+        invocations: list[tuple] = []
+
+        def cb(engine: str, idx: int, doc_id: str) -> None:
+            invocations.append((engine, idx, doc_id))
+
+        result = RunOrchestrator(tmp_path / "out").execute(
+            spec, progress_callback=cb,
+        )
+
+        assert result.run_result.n_documents == 1
+        # Phase B1.2 : le callback n'est pas encore invoqué (B2.1).
+        # Quand B2.1 sera fait, ce test sera dé-skippé et l'assertion
+        # passera à ``len(invocations) == 1``.
+
+    def test_execute_accepts_cancel_event(self, tmp_path: Path) -> None:
+        """``cancel_event`` est accepté en kwarg.
+
+        Phase B2.2 le branchera au CorpusRunner.
+        """
+        spec = _build_spec(tmp_path)
+        ev = threading.Event()
+
+        result = RunOrchestrator(tmp_path / "out").execute(
+            spec, cancel_event=ev,
+        )
+
+        assert result.run_result.n_documents == 1
+
+    def test_execute_without_new_kwargs_still_works(
+        self, tmp_path: Path,
+    ) -> None:
+        """Compat ascendante : un appel sans les nouveaux kwargs
+        fonctionne comme avant."""
+        spec = _build_spec(tmp_path)
+        result = RunOrchestrator(tmp_path / "out").execute(spec)
+        assert result.run_result.n_documents == 1
+
+    def test_execute_stores_kwargs_on_instance(self, tmp_path: Path) -> None:
+        """Phase B1.2 — les kwargs sont stockés sur l'instance.
+
+        Quand B2.1/B2.2 brancheront le câblage interne, ils liront
+        ``self._progress_callback`` et ``self._cancel_event``.
+        """
+        spec = _build_spec(tmp_path)
+
+        def cb(engine: str, idx: int, doc_id: str) -> None:
+            return None
+
+        ev = threading.Event()
+        orch = RunOrchestrator(tmp_path / "out")
+        orch.execute(spec, progress_callback=cb, cancel_event=ev)
+
+        # Les kwargs sont accessibles après execute().
+        assert orch._progress_callback is cb
+        assert orch._cancel_event is ev

tests/architecture/test_file_budgets.py

@@ -124,7 +124,8 @@ FILE_BUDGETS: dict[str, int] = {
     # --- Services applicatifs (couche 6).  Budgets ``current + 15 %``.
     "picarones/app/services/corpus_service.py": 625,      # actuel 541
     "picarones/app/services/path_security.py": 470,       # actuel 410
-    "picarones/app/services/run_orchestrator.py": 500,    # actuel 432
+    "picarones/app/services/run_orchestrator.py": 570,    # actuel 496 — Phase B1 migration Option B (+64 LOC)
+    "picarones/app/schemas/run_spec.py": 620,             # actuel 530 — Phase B1 migration Option B (+90 LOC : 7 nouveaux champs + 2 validators)
     "picarones/reports/html/render.py": 700,           # actuel 615
 }