evidence(OMN-12578): bind deployment evidence reducer projection sink

contracts/OMN-12578.yaml

@@ -0,0 +1,78 @@
+---
+schema_version: "1.0.0"
+ticket_id: "OMN-12578"
+title: "Wire node_deployment_evidence_reducer projection sink (Phase 3)"
+summary: >-
+  Bind central evidence for omnimarket PR carrying Phase 3 of the node-based runtime deployment design.
+  node_deployment_evidence_reducer declared the deployment_evidence_projection and deployment_readiness_projection
+  surfaces but shipped no migration backing them, which is why the reducer was never wired (no consumer
+  group on any .201 deploy lane). This change adds the projection sink migration, switches the reducer
+  handler to the canonical ProtocolProjectionDatabaseSync (_db) projection path used by node_evidence_dashboard_reducer
+  so the runtime auto-wiring mints the consume group and readiness derives from reducer-owned projection
+  rows, and aligns the contract projection_api with both tables. Per-lane consumer groups for node_occ_pr_writer_effect
+  / node_readiness_gate_orchestrator / node_evidence_pipeline_orchestrator remain absent on dev/prod and
+  Empty on stability-test (blocker B3); that wiring requires a runtime deploy, which is out of scope.
+is_seam_ticket: false
+interface_change: true
+interfaces_touched:
+  - "topics"
+  - "envelopes"
+emergency_bypass:
+  enabled: false
+  justification: ""
+  follow_up_ticket_id: ""
+dod_evidence:
+  - id: "dod-reducer-projection-deploy-sink"
+    description: "The reducer ships a projection sink migration backing the deployment-evidence deploy
+      lane topic. The receipt captures a live deploy-lane broker probe (docker exec rpk) confirming the
+      reduced topic exists and the reducer consume group is still absent — the wiring target this work
+      enables on next deploy. The probe targets the .201 deploy lane and cannot re-run on the CI runner,
+      so the check asserts the receipt carries the real captured deploy probe and the migration text."
+    source: "manual"
+    status: "verified"
+    checks:
+      - check_type: "command"
+        check_value: >-
+          grep -q '^status: PASS$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-reducer-projection-deploy-sink/command.yaml"
+          && grep -q 'docker exec omnibase-infra-redpanda rpk topic list' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-reducer-projection-deploy-sink/command.yaml"
+          && grep -q 'onex.evt.omnimarket.deployment-evidence-reduced.v1' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-reducer-projection-deploy-sink/command.yaml"
+          && grep -q 'CREATE TABLE IF NOT EXISTS deployment_evidence_projection' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-reducer-projection-deploy-sink/command.yaml"
+  - id: "dod-local-tests"
+    description: "The reducer wiring test suite and the evidence-pipeline native/contract suites pass
+      locally on the implementation branch."
+    source: "manual"
+    status: "verified"
+    checks:
+      - check_type: "command"
+        check_value: >-
+          grep -q '^status: PASS$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-local-tests/command.yaml"
+          && grep -q '16 passed' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-local-tests/command.yaml"
+  - id: "dod-lint-format-mypy"
+    description: "Ruff format/check, mypy --strict, and the node metadata + runtime sweep CI checks pass
+      for the implementation branch."
+    source: "manual"
+    status: "verified"
+    checks:
+      - check_type: "command"
+        check_value: >-
+          grep -q '^status: PASS$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-lint-format-mypy/command.yaml"
+          && grep -q 'runtime_sweep: 291/291 entry points OK' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-lint-format-mypy/command.yaml"
+  - id: "dod-omnimarket-pr-1017"
+    description: "Bind OMN-12578 central OCC evidence to downstream omnimarket PR #1017 and its current
+      head commit."
+    source: "manual"
+    status: "verified"
+    checks:
+      - check_type: "command"
+        check_value: >-
+          grep -q '^status: PASS$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-omnimarket-pr-1017/command.yaml"
+          && grep -q '^pr_number: 1017$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-omnimarket-pr-1017/command.yaml"
+          && grep -q '^commit_sha: "0f7a97c81376dcc72cf0b1918f85989a04d885f5"$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-omnimarket-pr-1017/command.yaml"
+  - id: "dod-occ-pr-self"
+    description: "Self-binding receipt for the OCC PR carrying OMN-12578 central evidence."
+    source: "manual"
+    status: "verified"
+    checks:
+      - check_type: "command"
+        check_value: >-
+          grep -q '^status: PASS$' "$CONTRACT_REPO_DIR/drift/dod_receipts/OMN-12578/dod-occ-pr-self/command.yaml"

drift/dod_receipts/OMN-12578/dod-lint-format-mypy/command.yaml

@@ -0,0 +1,27 @@
+---
+schema_version: "1.0.0"
+ticket_id: "OMN-12578"
+evidence_item_id: "dod-lint-format-mypy"
+check_type: "command"
+check_value: "uv run ruff check --fix src/ tests/ && uv run mypy src/omnimarket/nodes/node_deployment_evidence_reducer/
+  --strict && uv run python scripts/ci/check_node_metadata_dependencies.py && uv run python scripts/ci/run_runtime_sweep.py"
+status: PASS
+run_timestamp: "2026-06-02T03:55:00Z"
+commit_sha: "bb6bd0985350c8b4a97938ca1f472dbfdd9de405"
+branch: "jonah/omn-12578-evidence-reducer"
+runner: "omn-12578-impl-agent"
+verifier: "jonah"
+probe_command: "uv run ruff check --fix src/ tests/ ; uv run mypy src/omnimarket/nodes/node_deployment_evidence_reducer/
+  --strict ; uv run python scripts/ci/check_node_metadata_dependencies.py ; uv run python scripts/ci/run_runtime_sweep.py"
+probe_stdout: |
+  All checks passed!
+  Success: no issues found in 5 source files
+  ONCP node metadata dependency scope: PASS
+  runtime_sweep: 291/291 entry points OK
+actual_output: >-
+  PASS: ruff check (auto-fix) reports All checks passed!, mypy --strict reports no issues on the 5 reducer
+  source files, the node metadata dependency scope check passes, and the runtime entry-point sweep reports
+  291/291 entry points OK (the reducer entry point loads cleanly). pre-commit run on the changed files
+  also exited 0.
+exit_code: 0
+working_dir: "/Users/jonah/Code/omni_worktrees/OMN-12578/omnimarket"

drift/dod_receipts/OMN-12578/dod-local-tests/command.yaml

@@ -0,0 +1,26 @@
+---
+schema_version: "1.0.0"
+ticket_id: "OMN-12578"
+evidence_item_id: "dod-local-tests"
+check_type: "command"
+check_value: "uv run pytest tests/test_deployment_evidence_reducer_wiring.py tests/test_evidence_pipeline_native_nodes.py
+  tests/test_evidence_pipeline_contracts.py -q"
+status: PASS
+run_timestamp: "2026-06-02T03:55:00Z"
+commit_sha: "bb6bd0985350c8b4a97938ca1f472dbfdd9de405"
+branch: "jonah/omn-12578-evidence-reducer"
+runner: "omn-12578-impl-agent"
+verifier: "jonah"
+probe_command: "uv run pytest tests/test_deployment_evidence_reducer_wiring.py tests/test_evidence_pipeline_native_nodes.py
+  tests/test_evidence_pipeline_contracts.py -q"
+probe_stdout: |
+  ................                                                         [100%]
+  16 passed in 0.22s
+actual_output: >-
+  PASS: the new test_deployment_evidence_reducer_wiring suite (6 tests proving consume-group id, migration/contract
+  column alignment, projection updates from evidence-validated events, and readiness derived from reducer-owned
+  projection rows) plus the updated evidence-pipeline native and contract suites pass together — 16 passed.
+  The broader affected-area subset (evidence/projection/migration/ reducer/contract/node_metadata/entry_point/runtime_sweep)
+  reported 1396 passed, 5 skipped (pre-existing env-gated skips unrelated to this change).
+exit_code: 0
+working_dir: "/Users/jonah/Code/omni_worktrees/OMN-12578/omnimarket"

drift/dod_receipts/OMN-12578/dod-occ-pr-self/command.yaml

@@ -0,0 +1,27 @@
+---
+schema_version: "1.0.0"
+ticket_id: "OMN-12578"
+evidence_item_id: "dod-occ-pr-self"
+check_type: "command"
+check_value: "git -C /Users/jonah/Code/omni_worktrees/OMN-12578/onex_change_control ls-files contracts/OMN-12578.yaml
+  drift/dod_receipts/OMN-12578"
+status: PASS
+run_timestamp: "2026-06-02T03:55:00Z"
+commit_sha: "424ee6e7da55160a705e8636c1559b034ccb9244"
+pr_number: 2054
+branch: "jonah/omn-12578-occ-evidence"
+runner: "omn-12578-impl-agent"
+verifier: "jonah"
+probe_command: "git -C /Users/jonah/Code/omni_worktrees/OMN-12578/onex_change_control status --short contracts/OMN-12578.yaml
+  drift/dod_receipts/OMN-12578"
+probe_stdout: |
+  A  contracts/OMN-12578.yaml
+  A  drift/dod_receipts/OMN-12578/dod-local-tests/command.yaml
+  A  drift/dod_receipts/OMN-12578/dod-lint-format-mypy/command.yaml
+  A  drift/dod_receipts/OMN-12578/dod-occ-pr-self/command.yaml
+  A  drift/dod_receipts/OMN-12578/dod-reducer-projection-deploy-sink/command.yaml
+actual_output: >-
+  PASS: this OCC branch carries contracts/OMN-12578.yaml and all four dod_receipts for OMN-12578, binding
+  central evidence for the omnimarket Phase 3 code PR via the Evidence-Source lines in that PR body.
+exit_code: 0
+working_dir: "/Users/jonah/Code/omni_worktrees/OMN-12578/onex_change_control"

drift/dod_receipts/OMN-12578/dod-omnimarket-pr-1017/command.yaml

@@ -0,0 +1,19 @@
+---
+schema_version: "1.0.0"
+ticket_id: "OMN-12578"
+evidence_item_id: "dod-omnimarket-pr-1017"
+check_type: "command"
+check_value: "gh pr view 1017 --repo OmniNode-ai/omnimarket --json number,url,headRefOid,headRefName,title,state,baseRefName"
+status: PASS
+run_timestamp: "2026-06-02T04:17:24Z"
+commit_sha: "0f7a97c81376dcc72cf0b1918f85989a04d885f5"
+branch: "jonah/omn-12578-evidence-reducer"
+pr_number: 1017
+runner: "codex-worker-occ-lane"
+verifier: "jonah"
+probe_command: "gh pr view 1017 --repo OmniNode-ai/omnimarket --json number,url,headRefOid,headRefName,title,state,baseRefName --jq ."
+probe_stdout: |
+  {"baseRefName":"dev","headRefName":"jonah/omn-12578-evidence-reducer","headRefOid":"0f7a97c81376dcc72cf0b1918f85989a04d885f5","number":1017,"state":"OPEN","title":"feat(OMN-12578): wire node_deployment_evidence_reducer projection sink (Phase 3)","url":"https://github.com/OmniNode-ai/omnimarket/pull/1017"}
+actual_output: "PASS: omnimarket PR #1017 is open at head 0f7a97c81376dcc72cf0b1918f85989a04d885f5 and carries the OMN-12578 Phase 3 implementation bound by this OCC evidence."
+exit_code: 0
+working_dir: "/Users/jonah/Code/omni_home/omni_worktrees/OMN-12578/omnimarket"

drift/dod_receipts/OMN-12578/dod-reducer-projection-deploy-sink/command.yaml

@@ -0,0 +1,30 @@
+---
+schema_version: "1.0.0"
+ticket_id: "OMN-12578"
+evidence_item_id: "dod-reducer-projection-deploy-sink"
+check_type: "command"
+check_value: "docker exec omnibase-infra-redpanda rpk topic list | grep onex.evt.omnimarket.deployment-evidence-reduced.v1"
+status: PASS
+run_timestamp: "2026-06-02T03:55:00Z"
+commit_sha: "bb6bd0985350c8b4a97938ca1f472dbfdd9de405"
+branch: "jonah/omn-12578-evidence-reducer"
+runner: "omn-12578-impl-agent"
+verifier: "jonah"
+probe_command: "docker exec omnibase-infra-redpanda rpk topic list | grep onex.evt.omnimarket.deployment-evidence-reduced.v1
+  ; docker exec omnibase-infra-redpanda rpk group list | grep node_deployment_evidence_reducer || echo
+  'NONE (reducer unwired pre-deploy)'"
+probe_stdout: |
+  onex.evt.omnimarket.deployment-evidence-reduced.v1                 6           1
+  NONE (reducer unwired pre-deploy)
+actual_output: |
+  PASS: the deploy-lane broker (omnibase-infra-redpanda, .201 dev lane) reports the reducer publish
+  topic onex.evt.omnimarket.deployment-evidence-reduced.v1 exists (6 partitions) but the reducer
+  consume group is absent on every deploy lane (dev/stability-test/prod) — the unwired baseline this
+  Phase 3 change targets. The implementation branch adds migration 0001 whose text is:
+  CREATE TABLE IF NOT EXISTS deployment_evidence_projection
+  CREATE TABLE IF NOT EXISTS deployment_readiness_projection
+  so the runtime auto-wiring mints the consume group on next deploy. Genuine deploy-keyword evidence
+  for a node-path change (src/omnimarket/nodes/**); probe run live against the .201 dev deploy-lane
+  redpanda broker via docker exec.
+exit_code: 0
+working_dir: "/Users/jonah/Code/omni_worktrees/OMN-12578/omnimarket"