Skip to content

feat(OMN-20578): vendor the routing-feedback and alert-channel liveness projection migrations ahead of omnimarket#3416 and #3417 #4573

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jonahgabriel merged 4 commits into from
Oct 5, 2026
Merged

feat(OMN-20578): vendor the routing-feedback and alert-channel liveness projection migrations ahead of omnimarket#3416 and #3417 #4573

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
1d31e2e
feat(OMN-20578): vendor the routing-feedback and alert-channel livene…
onexbot-occ-writer[bot] Oct 5, 2026
653c5cb
fix(OMN-20578): re-vendor routing feedback with its shape reconciliat…
jonahgabriel Oct 5, 2026
8a67465
test(OMN-20578): expect forward-only for the reconciled routing feedb…
jonahgabriel Oct 5, 2026
e54b942
chore(OMN-20578): re-run CI against the omnimarket#3420 source pair
jonahgabriel Oct 5, 2026
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
4 changes: 4 additions & 0 deletions config/migration_classes.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,8 @@ migrations:
forward/nodes/node_pr_merged_projection/0001_create_pr_merged_events.sql: forward-only # EXECUTE; ALTER TABLE ADD CONSTRAINT PR_MERGED_EVENTS_PKEY; ALTER TABLE ADD CONSTRAINT PR_MERGED_EVENTS_EVENT_I
forward/nodes/node_pr_merged_projection/0002_grant_omninode_runtime_pr_merged_events.sql: forward-only # EXECUTE
forward/nodes/node_pr_review_bot/001_create_review_bot_bypass_log.sql: expand-only
forward/nodes/node_projection_alert_channel_liveness/0000_create_alert_channel_liveness_verdicts.sql: forward-only # CREATE UNIQUE INDEX idx_alert_channel_liveness_cursor on omninode_internal.alert_channel_liveness_verdicts (UNIQUE INDEX class)
forward/nodes/node_projection_alert_channel_liveness/0001_grant_omninode_runtime_alert_channel_liveness_verdicts.sql: expand-only # additive
forward/nodes/node_projection_baselines/0001_create_baselines_tables.sql: forward-only # EXECUTE; ALTER TABLE ADD CONSTRAINT BASELINES_SNAPSHOTS_PKEY; ALTER TABLE ADD CONSTRAINT BASELINES_COMPARISONS
forward/nodes/node_projection_baselines/0002_realign_child_tables_to_producer_schema.sql: forward-only # DROP; EXECUTE; ALTER TABLE ADD CONSTRAINT BASELINES_COMPARISONS_PKEY; ALTER TABLE ADD CONSTRAINT BASELINES_TRE
forward/nodes/node_projection_baselines/0003_grant_omninode_runtime_baselines_tables.sql: expand-only
Expand Down Expand Up @@ -327,6 +329,8 @@ migrations:
forward/nodes/node_projection_routing_decision/0021_create_agent_routing_decisions.sql: forward-only # EXECUTE; ALTER TABLE ADD CONSTRAINT AGENT_ROUTING_DECISIONS_PKEY
forward/nodes/node_projection_routing_decision/0022_agent_routing_decisions_tenant_id_and_rls.sql: forward-only # ALTER TABLE ENABLE ROW LEVEL; ALTER TABLE FORCE ROW LEVEL; DROP
forward/nodes/node_projection_routing_decision/0023_grant_tenant_projection_writer_agent_routing_decisions.sql: expand-only
forward/nodes/node_projection_routing_feedback/0000_create_delegation_routing_feedback.sql: forward-only # ALTER COLUMN; ADD CONSTRAINT
forward/nodes/node_projection_routing_feedback/0001_grant_tenant_projection_writer_delegation_routing_feedback.sql: expand-only # additive
forward/nodes/node_projection_runner_fleet/0000_create_runner_fleet_liveness.sql: forward-only # UNIQUE INDEX on an existing table
forward/nodes/node_projection_runner_fleet/0001_grant_omninode_runtime_runner_fleet_liveness.sql: expand-only
forward/nodes/node_projection_demo_readiness/0000_create_demo_readiness_latest.sql: forward-only # UNIQUE INDEX on created table
Expand Down
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/dogfood.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/judge.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/lakshman.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/local.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/onex-dev.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: 1a56dc18a7c273ce3457aee4d7604ac6b660670e95b18a7b5ed2e36a6a30d6f9
sha256: 58db2a4e041c88b30a55377e7abe0b6c79118d3fca3893c9ad6bd1436e548b6c
topology_instance: onex-dev
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/onex-prod.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: c82967925d6f584562df02e9d4ba0bd3e68fdde7aa68044b4133375a49d66d6d
sha256: 2f2ab465a0d5252715a993bca4248d3edf26b509a76b5a5616d314e7364567de
topology_instance: onex-prod
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/prod.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/stability-test.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 3 additions & 1 deletion docker/catalog/database-topology/test.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ databases:
schema: public
- object_type: TABLE
objects:
- alert_channel_liveness_verdicts
- board_probe_results
- ci_attempt_outcome
- claude_agent_spans
Expand Down Expand Up @@ -210,6 +211,7 @@ databases:
- delegation_eval_results
- delegation_events
- delegation_judge_verdict_events
- delegation_routing_feedback
- delegation_routing_tenant_overlay
- delegation_shadow_comparisons
- dep_health_findings
Expand Down Expand Up @@ -382,5 +384,5 @@ source:
profile_catalog_path: src/omnibase_infra/topology/application_database_profiles.yaml
profile_catalog_sha256: 690ada1927fc31465fd1d80435e82c96394fa05d49bd433e30242ea014fa740f
repository: OmniNode-ai/omnibase_infra
sha256: a58dbdde827c5a2a5514d490a7ac42c4aee36bb11cf885e045f98d57fd6f38ee
sha256: 8206b49ae2275e85e5e713466596340d19f7e52145daad02edb73e0fcd60e840
topology_instance: local
4 changes: 4 additions & 0 deletions docker/migrations/forward/_ledger/application-migrations.tsv
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,8 @@ nodes/node_pr_lifecycle_state_reducer/0003_grant_omninode_runtime_pr_lifecycle_s
nodes/node_pr_merged_projection/0001_create_pr_merged_events.sql node:node_pr_merged_projection node:node_pr_merged_projection omninode_internal node:node_pr_merged_projection:0001_create_pr_merged_events.sql 2835e23571dee7bec83c4ff75ada048929e1efb771a1d3be2bfb7b759a995070
nodes/node_pr_merged_projection/0002_grant_omninode_runtime_pr_merged_events.sql node:node_pr_merged_projection node:node_pr_merged_projection omninode_internal node:node_pr_merged_projection:0002_grant_omninode_runtime_pr_merged_events.sql 54d24039a31c893b105e55a50fb20cc7a07304a6e0e8e68fe40b78830eecf88b
nodes/node_pr_review_bot/001_create_review_bot_bypass_log.sql node:node_pr_review_bot node:node_pr_review_bot omninode_internal node:node_pr_review_bot:001_create_review_bot_bypass_log.sql 63e2646a7f8767fad9ec969b224982e00b83aacb665107ab5b103964d5616e00
nodes/node_projection_alert_channel_liveness/0000_create_alert_channel_liveness_verdicts.sql node:node_projection_alert_channel_liveness node:node_projection_alert_channel_liveness omninode_internal node:node_projection_alert_channel_liveness:0000_create_alert_channel_liveness_verdicts.sql b6dd14f636a520a00d561ec37fad1f00c43af931ec4b7b82ea224824a22808f9
nodes/node_projection_alert_channel_liveness/0001_grant_omninode_runtime_alert_channel_liveness_verdicts.sql node:node_projection_alert_channel_liveness node:node_projection_alert_channel_liveness omninode_internal node:node_projection_alert_channel_liveness:0001_grant_omninode_runtime_alert_channel_liveness_verdicts.sql b15100c7de5b769a8a2f946f2123fa5b101311a58b1e885424586faa242b171b
nodes/node_projection_baselines/0001_create_baselines_tables.sql node:node_projection_baselines node:node_projection_baselines omninode_internal node:node_projection_baselines:0001_create_baselines_tables.sql f94dae78957a2890ea80655f3d2280331504d6637f9bdbd9ef014e2c33583f9d
nodes/node_projection_baselines/0002_realign_child_tables_to_producer_schema.sql node:node_projection_baselines node:node_projection_baselines omninode_internal node:node_projection_baselines:0002_realign_child_tables_to_producer_schema.sql b41a161c5a9e6325ced130c4d0217c72d2a2bd258effb4af5349401f3415ec30
nodes/node_projection_baselines/0003_grant_omninode_runtime_baselines_tables.sql node:node_projection_baselines node:node_projection_baselines omninode_internal node:node_projection_baselines:0003_grant_omninode_runtime_baselines_tables.sql eaeaba5f83c9e2ff62daee6e1d0ba064b53cde0e10c84e625e03989125936df5
Expand Down Expand Up @@ -212,6 +214,8 @@ nodes/node_projection_registration/0007_node_service_registry_drop_tenant_postur
nodes/node_projection_routing_decision/0021_create_agent_routing_decisions.sql node:node_projection_routing_decision node:node_projection_routing_decision omninode_internal node:node_projection_routing_decision:0021_create_agent_routing_decisions.sql 46d169e595f65ad89e7f524efffedb59eb0e1a37f9527e67f1ff2e8eaaa7711e
nodes/node_projection_routing_decision/0022_agent_routing_decisions_tenant_id_and_rls.sql node:node_projection_routing_decision node:node_projection_routing_decision tenant node:node_projection_routing_decision:0022_agent_routing_decisions_tenant_id_and_rls.sql bac8be9bbe6167601ca805d35a78f469a6bce9ca9fc22e88a363c50dac0b7f83
nodes/node_projection_routing_decision/0023_grant_tenant_projection_writer_agent_routing_decisions.sql node:node_projection_routing_decision node:node_projection_routing_decision tenant node:node_projection_routing_decision:0023_grant_tenant_projection_writer_agent_routing_decisions.sql 206b8658cd9cf583e05e47eb0c48f023b7ecdbf8b30ac15d8ddf3f45f1f4dffc
nodes/node_projection_routing_feedback/0000_create_delegation_routing_feedback.sql node:node_projection_routing_feedback node:node_projection_routing_feedback tenant node:node_projection_routing_feedback:0000_create_delegation_routing_feedback.sql 43803f20610fb1ddeed49046f6c04656c5a27dfe976f0212ecfa5614f06e60f0
nodes/node_projection_routing_feedback/0001_grant_tenant_projection_writer_delegation_routing_feedback.sql node:node_projection_routing_feedback node:node_projection_routing_feedback tenant node:node_projection_routing_feedback:0001_grant_tenant_projection_writer_delegation_routing_feedback.sql 048e90f4046ec68a0de942791c5d14c670744c1e801b58438e323af7f4b60c59
nodes/node_projection_runner_fleet/0000_create_runner_fleet_liveness.sql node:node_projection_runner_fleet node:node_projection_runner_fleet omninode_internal node:node_projection_runner_fleet:0000_create_runner_fleet_liveness.sql 6373341362d9329f3db44fdd996e73b8205e57dccb2a1f40230442afef885b26
nodes/node_projection_runner_fleet/0001_grant_omninode_runtime_runner_fleet_liveness.sql node:node_projection_runner_fleet node:node_projection_runner_fleet omninode_internal node:node_projection_runner_fleet:0001_grant_omninode_runtime_runner_fleet_liveness.sql 45d9034a1cc168db210cca0efbedad23450b245c1bf9017a4562b61f9d5c4208
nodes/node_projection_runtime_error_fingerprints/0000_create_runtime_error_fingerprints.sql node:node_projection_runtime_error_fingerprints node:node_projection_runtime_error_fingerprints omninode_internal node:node_projection_runtime_error_fingerprints:0000_create_runtime_error_fingerprints.sql 1d7500c9f3c9aa82bb37eb17e4b3334f90136c46a8621627e2bb213a27e9bdc9
Expand Down
Loading
Loading