fix(OMN-14600): inline-recover in-flight-lock defer strand + re-pin core #1439

.github/workflows/receipt-honesty.yml

@@ -80,11 +80,14 @@ jobs:
           version: "latest"
       - name: Set up Python 3.12
         run: uv python install 3.12
-      - name: Install omnibase_core (validator package) into a uv venv
+      - name: Install receipt-honesty validator runtime dependencies
         run: |
           set -euo pipefail
-          uv venv .honesty-venv --python 3.12
-          uv pip install --python .honesty-venv/bin/python .ci/omnibase_core
+          uv venv .honesty-venv --python 3.12 --seed
+          uv pip install --python .honesty-venv/bin/python \
+            "pydantic>=2.11.7,<3.0.0" \
+            "pyyaml>=6.0.2,<7.0.0"
+          .honesty-venv/bin/python -m pip install --no-deps .ci/omnibase_core
       - name: Identify changed DoD receipt YAMLs
         id: receipts
         run: |

docker/runners/runner-image.lock.json

@@ -1,12 +1,12 @@
 {
   "base_image_digest": "sha256:3ba65aa20f86a0fad9df2b2c259c613df006b2e6d0bfcc8a146afb8c525a9751",
   "gh_version": "2.67.0",
-  "identity_digest": "1742589d908dc188c04b284e3af6ef62",
+  "identity_digest": "8a9355b9644c810c16a778947e31e4cc",
   "image_version": 6,
   "kubectl_version": "1.32.1",
   "python_version": "3.12",
   "runner_version": "2.334.0",
-  "shared_env_digest": "03c0958c80f472a630357ba5",
+  "shared_env_digest": "891609c2acbfd142db5c0c77",
   "shared_env_install_args": "--frozen --all-extras --all-groups --no-install-project",
   "uv_version": "0.6.14"
 }

pyproject.toml

@@ -29,7 +29,9 @@ dependencies = [
     #   omnibase-core = { git = "https://github.com/org/omnibase_core.git", rev = "SHA" }
     # Remember to switch back to PyPI versions before merging to main.
     #
-    "omnibase-core==0.46.7",
+    # OMN-14600: bumped 0.46.7 -> 0.46.8; the [tool.uv.sources] git-rev override
+    # below pulls the merged core #1439 (terminal delegation classes) pre-release.
+    "omnibase-core==0.46.8",
     "omnibase-spi==0.23.1",
     # OMN-14190: canonical OCC stamp schema lives in omnibase_compat (OMN-14223).
     "omnibase-compat==0.5.6",
@@ -181,7 +183,7 @@ dev = [
 
 [tool.uv]
 override-dependencies = [
-    "omnibase-core==0.46.7",
+    "omnibase-core==0.46.8",
     "omnibase-spi==0.23.1",
     "omnibase-compat==0.5.6",
 ]
@@ -196,6 +198,14 @@ onex-change-control = { git = "https://github.com/OmniNode-ai/onex_change_contro
 # omnibase-spi 0.23.1). The temporary immutable-rev git overrides for
 # omnibase-core/omnibase-spi were DELETED here and the version pins bumped to
 # the released exact versions, restoring a fully PyPI-sourced reproducible lock.
+#
+# OMN-14600: TEMPORARY git-rev override to import the terminal delegation
+# classes (ModelDelegationCompleted/ModelDelegationFailed) added by the MERGED
+# core #1439 squash commit a9f25887 on dev (self-reports 0.46.8), before that
+# commit is published to PyPI. The version pins above are already bumped to
+# 0.46.8 so the range stays consistent. REMOVE WHEN RELEASED: once core
+# publishes a version containing #1439, delete this override and `uv lock`.
+omnibase-core = { git = "https://github.com/OmniNode-ai/omnibase_core.git", rev = "a9f25887a51851ddf24258e6a7a507e7e56b28d8" }  # raw-override-ok: OMN-14600
 
 [tool.ruff]
 target-version = "py312"

src/omnibase_infra/contracts/handlers/db/handler_contract.yaml

@@ -30,6 +30,10 @@ output_model:
   name: "ModelHandlerOutput"
   module: "omnibase_core.models.dispatch.model_handler_output"
 handler_routing:
+  version:
+    major: 1
+    minor: 0
+    patch: 0
   routing_strategy: "operation_match"
   handlers:
     - handler_type: "db"

src/omnibase_infra/contracts/handlers/graph/handler_contract.yaml

@@ -38,6 +38,10 @@ output_model:
   name: "ModelHandlerOutput"
   module: "omnibase_core.models.dispatch.model_handler_output"
 handler_routing:
+  version:
+    major: 1
+    minor: 0
+    patch: 0
   routing_strategy: "operation_match"
   handlers:
     - handler_type: "graph"

src/omnibase_infra/contracts/handlers/http/handler_contract.yaml

@@ -22,6 +22,10 @@ output_model:
   name: "ModelHandlerOutput"
   module: "omnibase_core.models.dispatch.model_handler_output"
 handler_routing:
+  version:
+    major: 1
+    minor: 0
+    patch: 0
   routing_strategy: "operation_match"
   handlers:
     - handler_type: "http"

src/omnibase_infra/contracts/handlers/mcp/handler_contract.yaml

@@ -49,6 +49,10 @@ capability_outputs:
 input_model: omnibase_infra.handlers.models.mcp.ModelMcpToolCall
 output_model: omnibase_infra.handlers.models.mcp.ModelMcpToolResult
 handler_routing:
+  version:
+    major: 1
+    minor: 0
+    patch: 0
   routing_strategy: "operation_match"
   handlers:
     - handler_type: "mcp"

src/omnibase_infra/runtime/service_dispatch_result_applier.py

@@ -261,7 +261,17 @@ def _publish_payload_for_output_event(self, event: BaseModel) -> BaseModel:
         the bus and downstream consumers expect. Publishing the carrier verbatim
         would double-nest it (``ModelEventEnvelope(payload=ModelEventEnvelope(...))``),
         so a ``ModelEventEnvelope`` output event is always unwrapped to its inner
-        payload — mirroring the ``ModelDelegationEventEnvelope`` unwrap (OMN-13247).
+        payload (OMN-13247).
+
+        OMN-14600: the delegation orchestrator now emits the canonical
+        ``ModelEventEnvelope`` directly rather than the bespoke
+        ``ModelDelegationEventEnvelope`` carrier — but pre-fix in-flight rows
+        and any as-yet-unredeployed producer can still legitimately emit the
+        old shape, and the core class itself has NOT been deleted (a separate
+        cleanup PR owns that, to avoid a cross-repo release-ordering break).
+        KEEPING the special case here is deliberate: dropping it before the
+        old shape is provably gone from every live producer + every stored
+        row is a gratuitous skew risk for zero benefit this PR.
         """
         if type(event).__name__ in (
             "ModelEventEnvelope",

src/omnibase_infra/runtime/version_compatibility.py

@@ -175,7 +175,7 @@ def _build_matrix_from_pyproject(
 _FALLBACK_MATRIX: list[VersionConstraint] = [
     VersionConstraint(
         package="omnibase_core",
-        min_version="0.46.7",
+        min_version="0.46.8",
         max_version="0.47.0",
     ),
     VersionConstraint(

tests/integration/infra/test_omn_12765_release_backmerge_identity.py

@@ -18,15 +18,15 @@ def test_release_backmerge_preserves_proven_runtime_core_pin() -> None:
     clean, reproducible runtime image from immutable artifacts. The proven
     runtime inputs are now the released versions, not git revs.
 
-    OMN-14254 refresh: the proven runtime advances to core 0.46.7 while keeping
+    OMN-14600 refresh: the proven runtime advances to core 0.46.8 while keeping
     the PyPI-sourced reproducible lock.
     """
 
     pyproject = (ROOT / "pyproject.toml").read_text(encoding="utf-8")
     uv_lock = (ROOT / "uv.lock").read_text(encoding="utf-8")
 
     # The proven runtime now pins the published PyPI releases (exact versions).
-    assert "omnibase-core==0.46.7" in pyproject
+    assert "omnibase-core==0.46.8" in pyproject
     assert "omnibase-spi==0.23.1" in pyproject
 
     # The retired git-rev overrides must be gone from both manifest and lock:
@@ -49,5 +49,5 @@ def test_release_backmerge_preserves_runner_identity_lock() -> None:
 
     # OMN-14524: the regenerated image_version=6 identity binds the current dev
     # shared environment digest after the validation-ledger write-effect lane.
-    assert lock["identity_digest"] == "1742589d908dc188c04b284e3af6ef62"
-    assert lock["shared_env_digest"] == "03c0958c80f472a630357ba5"
+    assert lock["identity_digest"] == "8a9355b9644c810c16a778947e31e4cc"
+    assert lock["shared_env_digest"] == "891609c2acbfd142db5c0c77"

tests/integration/runtime/test_dynamic_contract_registration_e2e.py

@@ -59,6 +59,10 @@
     - onex.evt.test.e2e-dynamic.v1
   publish_topics: []
 handler_routing:
+  version:
+    major: 1
+    minor: 0
+    patch: 0
   routing_strategy: payload_type_match
   handlers:
     - handler:

tests/integration/test_kafka_contract_source_default_handler.py

@@ -39,6 +39,10 @@ def test_kafka_contract_source_materializes_default_handler_shorthand() -> None:
             - onex.evt.test.default-handler-completed.v1
           consumer_purpose: consume
         handler_routing:
+          version:
+            major: 1
+            minor: 0
+            patch: 0
           default_handler: tests.fixtures.handler_proof_noop:HandlerProofNoop
         """
     )