diff --git a/adapters/codex-cli/src/nemo_fabric_adapters/codex_cli/adapter.py b/adapters/codex-cli/src/nemo_fabric_adapters/codex_cli/adapter.py index 974e81084..0f135a5b1 100755 --- a/adapters/codex-cli/src/nemo_fabric_adapters/codex_cli/adapter.py +++ b/adapters/codex-cli/src/nemo_fabric_adapters/codex_cli/adapter.py @@ -689,7 +689,6 @@ def run_codex(payload: dict[str, Any]) -> dict[str, Any]: ) output["relay_runtime"] = { "enabled": True, - "mode": os.environ.get("FABRIC_RELAY_MODE"), "config_path": os.environ.get("FABRIC_RELAY_CONFIG_PATH"), "emitter": "nemo-relay", } diff --git a/adapters/hermes-cli/src/nemo_fabric_adapters/hermes_cli/adapter.py b/adapters/hermes-cli/src/nemo_fabric_adapters/hermes_cli/adapter.py index 985f87df4..9cf4800fe 100755 --- a/adapters/hermes-cli/src/nemo_fabric_adapters/hermes_cli/adapter.py +++ b/adapters/hermes-cli/src/nemo_fabric_adapters/hermes_cli/adapter.py @@ -137,7 +137,6 @@ def run_hermes_cli(payload: dict[str, Any]) -> dict[str, Any]: relay_artifacts = common_utils.collect_relay_artifacts(relay_plugin_config) output["relay_runtime"] = { "enabled": True, - "mode": os.environ.get("FABRIC_RELAY_MODE"), "config_path": os.environ.get("FABRIC_RELAY_CONFIG_PATH"), "emitter": "hermes.observability/nemo_relay", } diff --git a/adapters/hermes-sdk/src/nemo_fabric_adapters/hermes_sdk/adapter.py b/adapters/hermes-sdk/src/nemo_fabric_adapters/hermes_sdk/adapter.py index cdc614ac1..72f291231 100755 --- a/adapters/hermes-sdk/src/nemo_fabric_adapters/hermes_sdk/adapter.py +++ b/adapters/hermes-sdk/src/nemo_fabric_adapters/hermes_sdk/adapter.py @@ -151,7 +151,6 @@ async def run_hermes_sdk(payload: dict[str, Any]) -> dict[str, Any]: if relay_plugin_config is not None: output["relay_runtime"] = { "enabled": True, - "mode": os.environ.get("FABRIC_RELAY_MODE"), "config_path": os.environ.get("FABRIC_RELAY_CONFIG_PATH"), "emitter": "hermes.observability/nemo_relay", } diff --git a/crates/fabric-core/src/runtime.rs b/crates/fabric-core/src/runtime.rs index f5b06f2d5..12b527426 100644 --- a/crates/fabric-core/src/runtime.rs +++ b/crates/fabric-core/src/runtime.rs @@ -23,7 +23,6 @@ use crate::config::{ use crate::error::{FabricError, Result}; static NEXT_ID: AtomicU64 = AtomicU64::new(1); -const RELAY_RUNTIME_MODE: &str = "sdk"; #[cfg(test)] static TEST_STOPPED_AGENTS: Mutex> = Mutex::new(Vec::new()); @@ -1683,7 +1682,6 @@ fn prepare_relay_runtime_config( "schema_version": "fabric.relay/v1alpha1", "relay": { "enabled": true, - "mode": RELAY_RUNTIME_MODE, "project": telemetry.relay_project.clone(), "output_dir": telemetry .relay_output_dir @@ -1721,10 +1719,6 @@ fn prepare_relay_runtime_config( path: path.clone(), env: BTreeMap::from([ ("FABRIC_RELAY_ENABLED".to_string(), "true".to_string()), - ( - "FABRIC_RELAY_MODE".to_string(), - RELAY_RUNTIME_MODE.to_string(), - ), ( "FABRIC_RELAY_CONFIG_PATH".to_string(), path.to_string_lossy().into_owned(), diff --git a/tests/e2e/test_hermes_e2e.py b/tests/e2e/test_hermes_e2e.py index b66e8c52d..062f39ca1 100644 --- a/tests/e2e/test_hermes_e2e.py +++ b/tests/e2e/test_hermes_e2e.py @@ -83,7 +83,6 @@ async def test_artifacts(self): assert output["base_url"] == f"{self.api_server}/v1" assert output["error"] is None assert output["relay_runtime"]["enabled"] is True - assert output["relay_runtime"]["mode"] == "sdk" assert output["relay_runtime"]["emitter"] == "hermes.observability/nemo_relay" assert output["failed"] is False