Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
44 changes: 44 additions & 0 deletions contracts/OMN-12448.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
---
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"
- 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"
Original file line number Diff line number Diff line change
@@ -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:9b9ac7dae29659aac99f05139f3326bebbe0bfa6956e4a5a595281ade4e931be"
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"
Original file line number Diff line number Diff line change
@@ -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"
Original file line number Diff line number Diff line change
@@ -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:9b9ac7dae29659aac99f05139f3326bebbe0bfa6956e4a5a595281ade4e931be"
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"
Loading