feat(OMN-11998): add 082_swarm_runs migration for swarm dispatch projection

docker/migrations/forward/082_swarm_runs.sql

@@ -0,0 +1,33 @@
+-- Swarm dispatch projection table (OMN-11998)
+-- Owned by node_projection_swarm in omnimarket
+CREATE TABLE IF NOT EXISTS swarm_runs (
+  run_id            TEXT PRIMARY KEY,
+  correlation_id    TEXT NOT NULL,
+  status            TEXT NOT NULL,
+  task_hash         TEXT NOT NULL DEFAULT '',
+  subtask_count     INTEGER NOT NULL DEFAULT 0,
+  succeeded_count   INTEGER NOT NULL DEFAULT 0,
+  failed_count      INTEGER NOT NULL DEFAULT 0,
+  skipped_count     INTEGER NOT NULL DEFAULT 0,
+  models_used       TEXT[] DEFAULT '{}',
+  machines_used     TEXT[] DEFAULT '{}',
+  total_cost_usd                DOUBLE PRECISION DEFAULT 0.0,
+  cloud_equivalent_cost_usd     DOUBLE PRECISION DEFAULT 0.0,
+  savings_usd                   DOUBLE PRECISION DEFAULT 0.0,
+  parallelism_speedup_ratio     DOUBLE PRECISION DEFAULT 1.0,
+  decomposition_latency_ms      INTEGER DEFAULT 0,
+  dispatch_wall_latency_ms      INTEGER DEFAULT 0,
+  aggregation_latency_ms        INTEGER DEFAULT 0,
+  total_latency_ms              INTEGER DEFAULT 0,
+  endpoint_registry_hash        TEXT DEFAULT '',
+  registry_schema_version       TEXT DEFAULT '',
+  projection_cursor             TEXT DEFAULT '',
+  source_event_id               TEXT DEFAULT '',
+  source_topic                  TEXT DEFAULT '',
+  source_partition              INTEGER DEFAULT 0,
+  source_offset                 INTEGER DEFAULT 0,
+  reducer_version               TEXT DEFAULT '1.0.0',
+  freshness_state               TEXT DEFAULT 'fresh',
+  observed_at                   TIMESTAMPTZ,
+  created_at                    TIMESTAMPTZ NOT NULL DEFAULT NOW()
+);

docker/migrations/schema_fingerprint.sha256

@@ -1,6 +1,6 @@
 # Schema migration fingerprint for omnibase_infra (auto-generated)
 # Regenerate: python scripts/check_schema_fingerprint.py stamp
 # Verify:     python scripts/check_schema_fingerprint.py verify
-sha256:c73231978c0c8ef7b567c7fccf2918c291869f831da9039da48de3e207f158af
-generated_at: 2026-05-22T14:49:20Z
-migration_file_count: 67
+sha256:1f9089477a08750f5b925e291252c2090e591b09593617793b5eb0f837130de7
+generated_at: 2026-05-25T15:02:15Z
+migration_file_count: 68

src/omnibase_infra/adapters/llm/adapter_llm_provider_openai.py

@@ -203,8 +203,8 @@ def __init__(
         """Initialize the OpenAI-compatible provider adapter.
 
         Args:
-            base_url: Base URL of the LLM endpoint. Defaults to
-                ``LLM_CODER_URL`` env var, falling back to ``http://localhost:8000``.
+            base_url: Base URL of the LLM endpoint. Defaults to the required
+                ``LLM_CODER_URL`` env var.
             default_model: Default model identifier.
             api_key: Optional API key for Bearer token auth.
             provider_name: Provider identifier for logging/routing.

src/omnibase_infra/runtime/service_kernel.py

@@ -2011,19 +2011,14 @@ async def _savings_on_message(
 
             # node_delegate_skill_orchestrator publishes completed/failed to omnimarket topics.
             # Without this applier the handler result is silently discarded and the CLI adapter
-            # times out waiting for the completed topic (OMN-11996).
-            from omnibase_infra.event_bus.topic_constants import (
-                TOPIC_DELEGATE_SKILL_COMPLETED,
-                TOPIC_DELEGATE_SKILL_FAILED,
-            )
-
+            # times out waiting for onex.evt.omnimarket.delegate-skill-completed.v1 (OMN-11996).
             auto_wiring_result_appliers["node_delegate_skill_orchestrator"] = (
                 DispatchResultApplier(
                     event_bus=event_bus,
-                    output_topic=TOPIC_DELEGATE_SKILL_COMPLETED,
+                    output_topic=EnumOmnimarketTopic.EVT_DELEGATE_SKILL_COMPLETED_V1.value,
                     allowed_output_topics=[
-                        TOPIC_DELEGATE_SKILL_COMPLETED,
-                        TOPIC_DELEGATE_SKILL_FAILED,
+                        EnumOmnimarketTopic.EVT_DELEGATE_SKILL_COMPLETED_V1.value,
+                        EnumOmnimarketTopic.EVT_DELEGATE_SKILL_FAILED_V1.value,
                     ],
                 )
             )