commit ae14a4bc218727c37cef34953bed21c98626a13d
parent d42fcda80966df1031bcd18f8587ead58ddb427f
Author: triesap <tyson@radroots.org>
Date: Sun, 14 Jun 2026 15:39:22 -0700
runtime: split assisted provider status
- rename the assisted runtime status contract away from bridge terminology
- expose provider_runtime status and provider runtime capabilities
- replace bridge unavailable states with provider runtime vocabulary
- update fixtures and stdio assertions for the new status contract
Diffstat:
10 files changed, 68 insertions(+), 55 deletions(-)
diff --git a/src/hyf_assist/contract.mojo b/src/hyf_assist/contract.mojo
@@ -1,7 +1,7 @@
from std.collections import List
-def assist_bridge_contract_version() -> Int:
+def assisted_runtime_contract_version() -> Int:
return 1
@@ -9,14 +9,14 @@ def provider_runtime_id() -> String:
return "hyf_provider_runtime"
-def assist_bridge_supported_business_capabilities() -> List[String]:
+def assisted_runtime_supported_business_capabilities() -> List[String]:
var capabilities = List[String]()
capabilities.append("query_rewrite")
return capabilities^
@fieldwise_init
-struct AssistBridgeStatus(Copyable, Movable):
+struct AssistedRuntimeStatus(Copyable, Movable):
var id: String
var kind: String
var contract_version: Int
diff --git a/src/hyf_runtime/config.mojo b/src/hyf_runtime/config.mojo
@@ -75,7 +75,7 @@ def assisted_execution_enabled(config: HyfLoadedRuntimeConfig) -> Bool:
return config.effective.runtime.allow_assisted
-def assist_bridge_configured(config: HyfLoadedRuntimeConfig) -> Bool:
+def assisted_runtime_configured(config: HyfLoadedRuntimeConfig) -> Bool:
return (
config.effective.assist.bridge_enabled
and not String(config.effective.assist.endpoint).strip() == ""
diff --git a/src/hyf_runtime/status.mojo b/src/hyf_runtime/status.mojo
@@ -1,6 +1,6 @@
from json import Value, loads
-from hyf_runtime.config import assist_bridge_configured
+from hyf_runtime.config import assisted_runtime_configured
from hyf_runtime.diagnostics import (
diagnostics_debug_override_dir_from_env,
effective_diagnostics_dir_for_runtime_paths,
@@ -75,12 +75,12 @@ def build_runtime_status_value(context: RuntimeStartupContext) raises -> Value:
Value(context.config.effective.runtime.allow_assisted),
)
effective.set(
- "assist_bridge_enabled",
+ "assisted_runtime_enabled",
Value(context.config.effective.assist.bridge_enabled),
)
effective.set(
- "assist_bridge_configured",
- Value(assist_bridge_configured(context.config)),
+ "assisted_runtime_configured",
+ Value(assisted_runtime_configured(context.config)),
)
effective.set(
"assist_transport",
diff --git a/src/hyf_stdio/control/assisted_runtime.mojo b/src/hyf_stdio/control/assisted_runtime.mojo
@@ -3,34 +3,34 @@ from std.collections import List
from json import Value, loads
from hyf_assist.contract import (
- AssistBridgeStatus,
- assist_bridge_contract_version,
- assist_bridge_supported_business_capabilities,
+ AssistedRuntimeStatus,
+ assisted_runtime_contract_version,
+ assisted_runtime_supported_business_capabilities,
provider_runtime_id,
)
from hyf_runtime.config import (
HyfLoadedRuntimeConfig,
- assist_bridge_configured,
+ assisted_runtime_configured,
assisted_execution_enabled,
)
def resolve_assisted_runtime_status(
config: HyfLoadedRuntimeConfig,
-) -> AssistBridgeStatus:
- var configured = assist_bridge_configured(config)
+) -> AssistedRuntimeStatus:
+ var configured = assisted_runtime_configured(config)
var state = "disabled_by_runtime_config"
if assisted_execution_enabled(config):
- state = "bridge_unavailable" if configured else "bridge_unconfigured"
+ state = "unavailable" if configured else "unconfigured"
var endpoint = String("")
if configured:
endpoint = String(config.effective.assist.endpoint)
- return AssistBridgeStatus(
+ return AssistedRuntimeStatus(
id=provider_runtime_id(),
- kind="deferred_provider_runtime",
- contract_version=assist_bridge_contract_version(),
+ kind="provider_runtime",
+ contract_version=assisted_runtime_contract_version(),
transport="deferred",
endpoint=endpoint,
backend_kind="deferred",
@@ -41,28 +41,28 @@ def resolve_assisted_runtime_status(
reachable=False,
state=state,
fallback_contract="deterministic_baseline_preserved",
- supported_business_capabilities=assist_bridge_supported_business_capabilities(),
+ supported_business_capabilities=assisted_runtime_supported_business_capabilities(),
)
def assisted_execution_state_for_capability(
- status: AssistBridgeStatus, capability_id: String
+ status: AssistedRuntimeStatus, capability_id: String
) -> String:
if capability_id != "query_rewrite":
- return "deferred"
+ return "unsupported_capability"
if status.state == "disabled_by_runtime_config":
return "disabled_by_runtime_config"
return status.state
def assisted_backend_available_for_capability(
- status: AssistBridgeStatus, capability_id: String
+ status: AssistedRuntimeStatus, capability_id: String
) -> Bool:
return False
def serialize_assisted_runtime_status_value(
- status: AssistBridgeStatus,
+ status: AssistedRuntimeStatus,
) raises -> Value:
var value = loads("{}")
value.set("id", Value(String(status.id)))
diff --git a/src/hyf_stdio/control/capabilities.mojo b/src/hyf_stdio/control/capabilities.mojo
@@ -97,7 +97,7 @@ def build_capabilities_output_with_runtime_context(
"assisted_runtime_capabilities", assisted_runtime_capabilities.copy()
)
output.set(
- "assisted_backend_capabilities", assisted_runtime_capabilities
+ "provider_runtime_capabilities", assisted_runtime_capabilities
)
output.set(
"request_context_contract",
diff --git a/src/hyf_stdio/control/status.mojo b/src/hyf_stdio/control/status.mojo
@@ -90,22 +90,16 @@ def build_status_output_with_runtime_context(
var execution_mode_request_behavior = loads("{}")
execution_mode_request_behavior.set("deterministic", Value("execute"))
var assisted_request_behavior = "provider_unavailable"
- if assist_runtime.kind == "assist_bridge":
- assisted_request_behavior = "bridge_unavailable"
if assist_runtime.state == "ready":
assisted_request_behavior = "execute"
elif assist_runtime.state == "disabled_by_runtime_config":
assisted_request_behavior = "disabled_by_runtime_config"
elif assist_runtime.state == "unconfigured":
- assisted_request_behavior = (
- "bridge_unconfigured"
- if assist_runtime.kind == "assist_bridge"
- else "provider_unconfigured"
- )
- elif assist_runtime.state == "bridge_unavailable":
- assisted_request_behavior = "bridge_unavailable"
- elif assist_runtime.state == "bridge_unconfigured":
- assisted_request_behavior = "bridge_unconfigured"
+ assisted_request_behavior = "provider_unconfigured"
+ elif assist_runtime.state == "invalid_config":
+ assisted_request_behavior = "invalid_config"
+ elif assist_runtime.state == "degraded":
+ assisted_request_behavior = "provider_degraded"
execution_mode_request_behavior.set(
"assisted", Value(String(assisted_request_behavior))
)
@@ -130,7 +124,8 @@ def build_status_output_with_runtime_context(
serialize_assisted_runtime_status_value(assist_runtime),
)
output.set(
- "assist_bridge", serialize_assisted_runtime_status_value(assist_runtime)
+ "provider_runtime",
+ serialize_assisted_runtime_status_value(assist_runtime),
)
var counts = loads("{}")
diff --git a/tests/fixtures/v1/scenarios/capabilities_ok.json b/tests/fixtures/v1/scenarios/capabilities_ok.json
@@ -29,17 +29,23 @@
"output.business_capabilities.1.callable": false,
"output.business_capabilities.1.disabled_reason": "deferred_bootstrap_capability",
"output.business_capabilities.2.id": "semantic_rank",
- "output.business_capabilities.2.assisted_execution": "deferred",
+ "output.business_capabilities.2.assisted_execution": "unsupported_capability",
"output.business_capabilities.2.implementation_status": "implemented",
"output.business_capabilities.6.id": "explain_result",
- "output.business_capabilities.6.assisted_execution": "deferred",
+ "output.business_capabilities.6.assisted_execution": "unsupported_capability",
"output.business_capabilities.6.implementation_status": "implemented",
"output.assisted_runtime_capabilities.0.id": "hyf_provider_runtime",
- "output.assisted_runtime_capabilities.0.kind": "deferred_provider_runtime",
+ "output.assisted_runtime_capabilities.0.kind": "provider_runtime",
"output.assisted_runtime_capabilities.0.contract_version": 1,
"output.assisted_runtime_capabilities.0.transport": "deferred",
"output.assisted_runtime_capabilities.0.backend_kind": "deferred",
"output.assisted_runtime_capabilities.0.state": "disabled_by_runtime_config",
+ "output.provider_runtime_capabilities.0.id": "hyf_provider_runtime",
+ "output.provider_runtime_capabilities.0.kind": "provider_runtime",
+ "output.provider_runtime_capabilities.0.contract_version": 1,
+ "output.provider_runtime_capabilities.0.transport": "deferred",
+ "output.provider_runtime_capabilities.0.backend_kind": "deferred",
+ "output.provider_runtime_capabilities.0.state": "disabled_by_runtime_config",
"output.request_context_contract.accepted_features": [
"consumer",
"execution_mode_preference",
@@ -62,6 +68,9 @@
"contains_all": {
"output.assisted_runtime_capabilities.0.supported_business_capabilities": [
"query_rewrite"
+ ],
+ "output.provider_runtime_capabilities.0.supported_business_capabilities": [
+ "query_rewrite"
]
},
"absent_paths": [
diff --git a/tests/fixtures/v1/scenarios/status_ok.json b/tests/fixtures/v1/scenarios/status_ok.json
@@ -36,11 +36,17 @@
"output.backend_reachability.deterministic_backend": "available",
"output.backend_reachability.assisted_backend": "disabled_by_runtime_config",
"output.assisted_runtime.id": "hyf_provider_runtime",
- "output.assisted_runtime.kind": "deferred_provider_runtime",
+ "output.assisted_runtime.kind": "provider_runtime",
"output.assisted_runtime.contract_version": 1,
"output.assisted_runtime.transport": "deferred",
"output.assisted_runtime.backend_kind": "deferred",
"output.assisted_runtime.state": "disabled_by_runtime_config",
+ "output.provider_runtime.id": "hyf_provider_runtime",
+ "output.provider_runtime.kind": "provider_runtime",
+ "output.provider_runtime.contract_version": 1,
+ "output.provider_runtime.transport": "deferred",
+ "output.provider_runtime.backend_kind": "deferred",
+ "output.provider_runtime.state": "disabled_by_runtime_config",
"output.counts.canonical_business_capabilities": 8,
"output.counts.deterministic_registered_business_capabilities": 3,
"output.counts.deterministic_implemented_business_capabilities": 3,
@@ -74,6 +80,9 @@
"output.assisted_runtime.supported_business_capabilities": [
"query_rewrite"
],
+ "output.provider_runtime.supported_business_capabilities": [
+ "query_rewrite"
+ ],
"output.disabled_capabilities": [
"filter_extraction",
"summarize_listing",
diff --git a/tests/test_hyf.mojo b/tests/test_hyf.mojo
@@ -465,24 +465,24 @@ def test_capabilities_output_reflects_registry_truth_for_all_business_capabiliti
assert_true(not _has_key(entry, "disabled_reason"))
assert_equal(
- output["assisted_backend_capabilities"][0]["id"].string_value(),
+ output["provider_runtime_capabilities"][0]["id"].string_value(),
"hyf_provider_runtime",
)
assert_equal(
- output["assisted_backend_capabilities"][0]["kind"].string_value(),
- "deferred_provider_runtime",
+ output["provider_runtime_capabilities"][0]["kind"].string_value(),
+ "provider_runtime",
)
assert_equal(
- output["assisted_backend_capabilities"][0]["transport"]
+ output["provider_runtime_capabilities"][0]["transport"]
.string_value(),
"deferred",
)
assert_equal(
- output["assisted_backend_capabilities"][0]["state"].string_value(),
+ output["provider_runtime_capabilities"][0]["state"].string_value(),
"disabled_by_runtime_config",
)
assert_equal(
- output["assisted_backend_capabilities"][0]["backend_kind"]
+ output["provider_runtime_capabilities"][0]["backend_kind"]
.string_value(),
"deferred",
)
diff --git a/tests/test_stdio_contract.mojo b/tests/test_stdio_contract.mojo
@@ -287,12 +287,12 @@ def test_status_loads_valid_runtime_config_truthfully() raises:
response["output"]["execution_mode_request_behavior"][
"assisted"
].string_value(),
- "bridge_unavailable",
+ "provider_unavailable",
)
assert_equal(
response["output"]["assisted_runtime"]["state"]
.string_value(),
- "bridge_unavailable",
+ "unavailable",
)
assert_equal(
response["output"]["assisted_runtime"]["id"]
@@ -302,7 +302,7 @@ def test_status_loads_valid_runtime_config_truthfully() raises:
assert_equal(
response["output"]["assisted_runtime"]["kind"]
.string_value(),
- "deferred_provider_runtime",
+ "provider_runtime",
)
assert_equal(
response["output"]["assisted_runtime"]["transport"]
@@ -313,7 +313,7 @@ def test_status_loads_valid_runtime_config_truthfully() raises:
response["output"]["backend_reachability"][
"assisted_backend"
].string_value(),
- "bridge_unavailable",
+ "unavailable",
)
assert_equal(
response["output"]["runtime"]["config"][
@@ -359,13 +359,13 @@ def test_status_loads_valid_runtime_config_truthfully() raises:
)
assert_equal(
response["output"]["runtime"]["config"]["effective"][
- "assist_bridge_enabled"
+ "assisted_runtime_enabled"
].bool_value(),
True,
)
assert_equal(
response["output"]["runtime"]["config"]["effective"][
- "assist_bridge_configured"
+ "assisted_runtime_configured"
].bool_value(),
True,
)
@@ -476,7 +476,7 @@ def test_capabilities_reports_configured_assist_runtime_deferred_truthfully() ra
response["output"]["business_capabilities"][0][
"assisted_execution"
].string_value(),
- "bridge_unavailable",
+ "unavailable",
)
assert_equal(
response["output"]["assisted_runtime_capabilities"][0][
@@ -488,13 +488,13 @@ def test_capabilities_reports_configured_assist_runtime_deferred_truthfully() ra
response["output"]["assisted_runtime_capabilities"][0][
"kind"
].string_value(),
- "deferred_provider_runtime",
+ "provider_runtime",
)
assert_equal(
response["output"]["assisted_runtime_capabilities"][0][
"state"
].string_value(),
- "bridge_unavailable",
+ "unavailable",
)
assert_equal(
response["output"]["assisted_runtime_capabilities"][0][
