From d7f9593d95bd215855dcd424729e9ed6edf825f3 Mon Sep 17 00:00:00 2001 From: jonahgabriel Date: Sat, 30 May 2026 08:29:13 -0400 Subject: [PATCH 1/2] evidence(OMN-12448): bind event bus startup receipts --- contracts/OMN-12448.yaml | 36 +++++++++++++++++++ .../dod-focused-event-bus-tests/command.yaml | 21 +++++++++++ .../dod-omnibase-infra-pr-1795/command.yaml | 25 +++++++++++++ 3 files changed, 82 insertions(+) create mode 100644 contracts/OMN-12448.yaml create mode 100644 drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml create mode 100644 drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml diff --git a/contracts/OMN-12448.yaml b/contracts/OMN-12448.yaml new file mode 100644 index 00000000000..f03846f5ab4 --- /dev/null +++ b/contracts/OMN-12448.yaml @@ -0,0 +1,36 @@ +--- +schema_version: "1.0.0" +ticket_id: "OMN-12448" +title: "Bound EventBusKafka consumer startup concurrency" +summary: > + Bound runtime Kafka consumer startup concurrency and retry transient consumer start failures so cold + runtime boot does not stampede the group coordinator and crash-loop when a single consumer times out. + The implementation is carried by omnibase_infra PR #1795 with contract-backed configuration fields on + ModelKafkaEventBusConfig and kafka_event_bus_config.yaml; no new environment fallback path is introduced. +is_seam_ticket: false +interface_change: true +interfaces_touched: + - "src/omnibase_infra/event_bus/models/config/model_kafka_event_bus_config.py" + - "src/omnibase_infra/event_bus/configs/kafka_event_bus_config.yaml" +emergency_bypass: + enabled: false + justification: "" + follow_up_ticket_id: "" +dod_evidence: + - id: "dod-omnibase-infra-pr-1795" + description: "omnibase_infra PR #1795 carries the bounded consumer-startup concurrency implementation at the cleaned dev-based head." + source: "manual" + status: "verified" + checks: + - check_type: "command" + check_value: "grep -q '^status: PASS$' drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml + && grep -q '^pr_number: 1795$' drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml + && grep -q '^commit_sha: \"72fbe42d0d5138a83b58f6d2364f4d1685f5281c\"$' drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml" + - id: "dod-focused-event-bus-tests" + description: "Focused EventBusKafka concurrency/retry tests pass locally against the cleaned OMN-12448 head." + source: "manual" + status: "verified" + checks: + - check_type: "command" + check_value: "grep -q '^status: PASS$' drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml + && grep -q '6 passed' drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml" diff --git a/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml b/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml new file mode 100644 index 00000000000..73251158939 --- /dev/null +++ b/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml @@ -0,0 +1,21 @@ +--- +schema_version: "1.0.0" +ticket_id: "OMN-12448" +evidence_item_id: "dod-focused-event-bus-tests" +check_type: "command" +check_value: "uv run pytest tests/integration/event_bus/test_kafka_concurrent_subscribe_startup.py -q" +contract_sha256: "sha256:4accb9ba5b5d5058b0b68c064c8fd18910d1f0413ef99279d3f2799730643676" +status: PASS +run_timestamp: "2026-05-30T12:23:00Z" +commit_sha: "72fbe42d0d5138a83b58f6d2364f4d1685f5281c" +runner: "codex-cli" +verifier: "manual-merge-sweep" +probe_command: "uv run pytest tests/integration/event_bus/test_kafka_concurrent_subscribe_startup.py -q" +probe_stdout: | + ...... [100%] + 6 passed in 0.72s +actual_output: "PASS: focused EventBusKafka concurrent subscribe startup tests passed at OMN-12448 head 72fbe42d0d5138a83b58f6d2364f4d1685f5281c." +exit_code: 0 +pr_number: 1795 +branch: "jonahgabriel/omn-12448-bound-consumer-startup-concurrency" +working_dir: "/Users/jonah/Code/omni_home/omni_worktrees/OMN-12448/omnibase_infra" diff --git a/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml b/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml new file mode 100644 index 00000000000..f57ef159d0c --- /dev/null +++ b/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml @@ -0,0 +1,25 @@ +--- +schema_version: "1.0.0" +ticket_id: "OMN-12448" +evidence_item_id: "dod-omnibase-infra-pr-1795" +check_type: "command" +check_value: "gh pr view 1795 --repo OmniNode-ai/omnibase_infra --json number,headRefOid,baseRefName,title,state" +contract_sha256: "sha256:4accb9ba5b5d5058b0b68c064c8fd18910d1f0413ef99279d3f2799730643676" +status: PASS +run_timestamp: "2026-05-30T12:24:00Z" +commit_sha: "72fbe42d0d5138a83b58f6d2364f4d1685f5281c" +runner: "codex-cli" +verifier: "manual-merge-sweep" +probe_command: "gh pr view 1795 --repo OmniNode-ai/omnibase_infra --json number,headRefOid,baseRefName,title,state" +probe_stdout: | + omnibase_infra PR #1795 was rebased from divergent main history onto origin/dev so the PR now contains + only the intended OMN-12448 feature delta: + - src/omnibase_infra/event_bus/configs/kafka_event_bus_config.yaml + - src/omnibase_infra/event_bus/event_bus_kafka.py + - src/omnibase_infra/event_bus/models/config/model_kafka_event_bus_config.py + - tests/integration/event_bus/test_kafka_concurrent_subscribe_startup.py +actual_output: "PASS: omnibase_infra PR #1795 head 72fbe42d0d5138a83b58f6d2364f4d1685f5281c carries the bounded EventBusKafka consumer startup fix on dev." +exit_code: 0 +pr_number: 1795 +branch: "jonahgabriel/omn-12448-bound-consumer-startup-concurrency" +working_dir: "/Users/jonah/Code/omni_home/omni_worktrees/OMN-12448/omnibase_infra" From 63e6561a96e2dd41723e1bb8faf315157b6d2d7b Mon Sep 17 00:00:00 2001 From: jonahgabriel Date: Sat, 30 May 2026 08:30:24 -0400 Subject: [PATCH 2/2] evidence(OMN-12448): bind OCC publication receipt --- contracts/OMN-12448.yaml | 8 +++++++ .../dod-focused-event-bus-tests/command.yaml | 2 +- .../dod-occ-pr-1900-self-binding/command.yaml | 22 +++++++++++++++++++ .../dod-omnibase-infra-pr-1795/command.yaml | 2 +- 4 files changed, 32 insertions(+), 2 deletions(-) create mode 100644 drift/dod_receipts/OMN-12448/dod-occ-pr-1900-self-binding/command.yaml diff --git a/contracts/OMN-12448.yaml b/contracts/OMN-12448.yaml index f03846f5ab4..9a80a2e89b3 100644 --- a/contracts/OMN-12448.yaml +++ b/contracts/OMN-12448.yaml @@ -34,3 +34,11 @@ dod_evidence: - check_type: "command" check_value: "grep -q '^status: PASS$' drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml && grep -q '6 passed' drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml" + - id: "dod-occ-pr-1900-self-binding" + description: "OCC PR #1900 publishes the central OMN-12448 contract and receipts required by downstream Receipt Gate." + source: "manual" + status: "verified" + checks: + - check_type: "command" + check_value: "grep -q '^status: PASS$' drift/dod_receipts/OMN-12448/dod-occ-pr-1900-self-binding/command.yaml + && grep -q '^pr_number: 1900$' drift/dod_receipts/OMN-12448/dod-occ-pr-1900-self-binding/command.yaml" diff --git a/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml b/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml index 73251158939..0fb88c01adc 100644 --- a/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml +++ b/drift/dod_receipts/OMN-12448/dod-focused-event-bus-tests/command.yaml @@ -4,7 +4,7 @@ ticket_id: "OMN-12448" evidence_item_id: "dod-focused-event-bus-tests" check_type: "command" check_value: "uv run pytest tests/integration/event_bus/test_kafka_concurrent_subscribe_startup.py -q" -contract_sha256: "sha256:4accb9ba5b5d5058b0b68c064c8fd18910d1f0413ef99279d3f2799730643676" +contract_sha256: "sha256:9b9ac7dae29659aac99f05139f3326bebbe0bfa6956e4a5a595281ade4e931be" status: PASS run_timestamp: "2026-05-30T12:23:00Z" commit_sha: "72fbe42d0d5138a83b58f6d2364f4d1685f5281c" diff --git a/drift/dod_receipts/OMN-12448/dod-occ-pr-1900-self-binding/command.yaml b/drift/dod_receipts/OMN-12448/dod-occ-pr-1900-self-binding/command.yaml new file mode 100644 index 00000000000..d05ee2caac1 --- /dev/null +++ b/drift/dod_receipts/OMN-12448/dod-occ-pr-1900-self-binding/command.yaml @@ -0,0 +1,22 @@ +--- +schema_version: "1.0.0" +ticket_id: "OMN-12448" +evidence_item_id: "dod-occ-pr-1900-self-binding" +check_type: "command" +check_value: "gh pr view 1900 --repo OmniNode-ai/onex_change_control --json number,headRefOid,baseRefName,title,state" +contract_sha256: "sha256:9b9ac7dae29659aac99f05139f3326bebbe0bfa6956e4a5a595281ade4e931be" +status: PASS +run_timestamp: "2026-05-30T12:35:00Z" +commit_sha: "d7f9593d9f9f48ef691f45d6881b9d2a1769e1ad" +runner: "codex-cli" +verifier: "manual-merge-sweep" +probe_command: "gh pr view 1900 --repo OmniNode-ai/onex_change_control --json number,headRefOid,baseRefName,title,state" +probe_stdout: | + onex_change_control PR #1900 opens against dev to publish central OMN-12448 receipts for omnibase_infra + PR #1795 after the downstream Receipt Gate failed because the PR body lacked an Evidence-Source line. + This self-binding receipt records the OCC evidence publication PR itself. +actual_output: "PASS: OCC PR #1900 publishes OMN-12448 central receipt bindings for omnibase_infra PR #1795." +exit_code: 0 +pr_number: 1900 +branch: "jonah/omn-12448-occ-evidence" +working_dir: "/Users/jonah/Code/omni_home/omni_worktrees/OMN-12448/onex_change_control" diff --git a/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml b/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml index f57ef159d0c..2319cc0fd66 100644 --- a/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml +++ b/drift/dod_receipts/OMN-12448/dod-omnibase-infra-pr-1795/command.yaml @@ -4,7 +4,7 @@ ticket_id: "OMN-12448" evidence_item_id: "dod-omnibase-infra-pr-1795" check_type: "command" check_value: "gh pr view 1795 --repo OmniNode-ai/omnibase_infra --json number,headRefOid,baseRefName,title,state" -contract_sha256: "sha256:4accb9ba5b5d5058b0b68c064c8fd18910d1f0413ef99279d3f2799730643676" +contract_sha256: "sha256:9b9ac7dae29659aac99f05139f3326bebbe0bfa6956e4a5a595281ade4e931be" status: PASS run_timestamp: "2026-05-30T12:24:00Z" commit_sha: "72fbe42d0d5138a83b58f6d2364f4d1685f5281c"