OpenTelemetry

View as Markdown

Use the opentelemetry section when you want NeMo Relay lifecycle events exported as generic OpenTelemetry Protocol (OTLP) trace spans.

OpenTelemetry export is a good fit when your tracing backend already expects OTLP spans and you want NeMo Relay scopes, tool calls, LLM calls, and marks to appear in the same tracing pipeline as the rest of the application.

plugins.toml Example

Add the following OpenTelemetry exporter configuration to plugins.toml:

1version = 1
2
3[[components]]
4kind = "observability"
5enabled = true
6
7[components.config]
8version = 1
9
10[components.config.opentelemetry]
11enabled = true
12transport = "http_binary"
13endpoint = "http://localhost:4318/v1/traces"
14service_name = "agent-service"
15service_namespace = "nemo"
16service_version = "1.0.0"
17instrumentation_scope = "nemo-relay-otel"
18timeout_millis = 3000
19
20[components.config.opentelemetry.headers]
21authorization = "Bearer <token>"
22
23[components.config.opentelemetry.resource_attributes]
24"deployment.environment" = "dev"

This configuration registers a plugin-owned OpenTelemetry subscriber and sends NeMo Relay trace spans to the configured OTLP endpoint.

Fields

The following table describes OpenTelemetry exporter settings:

FieldDefaultNotes
enabledfalseMust be true to construct and register the subscriber.
transporthttp_binaryhttp_binary or grpc.
endpointExporter defaultOTLP endpoint.
headers{}String-to-string exporter headers.
resource_attributes{}String-to-string OTLP resource attributes.
service_namenemo-relayservice.name resource attribute.
service_namespaceOmittedOptional service.namespace.
service_versionOmittedOptional service.version.
instrumentation_scopeOmittedOptional instrumentation scope name.
timeout_millis3000Export timeout.

Expected Output

The collector should receive OTLP trace export requests. The tracing backend should show spans for NeMo Relay scopes, tools, LLM calls, and marks grouped by root scope.

Each lifecycle span includes nemo_relay.uuid and nemo_relay.parent_uuid attributes. These values match ATIF step.extra.ancestry.function_id and step.extra.ancestry.parent_id for the same events. For plugin-managed ATIF, the trajectory-root span’s nemo_relay.uuid also matches the ATIF session_id. Backend-native trace_id and span_id values are not written into ATIF.

For LLM end spans, cost is emitted as nemo_relay.llm.cost.total and nemo_relay.llm.cost.currency (any currency). Token counts are not emitted as discrete attributes. Refer to Token and Cost Field Semantics for the full mapping.

Register the plugin before the first instrumented request, use stable service identity fields, keep credentials outside source code, and flush during graceful shutdown.

Plugin Configuration

Use plugin configuration when the application should let NeMo Relay own the OpenTelemetry subscriber lifecycle. The following examples configure and activate the OpenTelemetry exporter through each supported language binding.

validate() checks only the supplied in-memory object. initialize() also layers discovered plugins.toml configuration. For effective file-backed validation, refer to Plugin Configuration Files and run the gateway with the same configuration path that production uses.

1import asyncio
2
3from nemo_relay import plugin
4from nemo_relay.observability import ComponentSpec, ObservabilityConfig, OtlpConfig
5
6config = plugin.PluginConfig(
7 components=[
8 ComponentSpec(
9 ObservabilityConfig(
10 opentelemetry=OtlpConfig(
11 enabled=True,
12 transport="http_binary",
13 endpoint="http://localhost:4318/v1/traces",
14 service_name="agent-service",
15 service_namespace="nemo",
16 service_version="1.0.0",
17 instrumentation_scope="nemo-relay-otel",
18 resource_attributes={"deployment.environment": "dev"},
19 headers={"authorization": "Bearer <token>"},
20 )
21 )
22 )
23 ]
24)
25
26report = plugin.validate(config)
27if any(diagnostic["level"] == "error" for diagnostic in report["diagnostics"]):
28 raise RuntimeError(report["diagnostics"])
29
30async def main():
31 await plugin.initialize(config)
32 try:
33 # Run instrumented application work here.
34 pass
35 finally:
36 plugin.clear()
37
38asyncio.run(main())

Manual API

Use the manual subscriber API when you need an explicit subscriber name or direct force_flush control.

1from nemo_relay import OpenTelemetryConfig, OpenTelemetrySubscriber
2
3config = OpenTelemetryConfig()
4config.transport = "http_binary"
5config.endpoint = "http://localhost:4318/v1/traces"
6config.service_name = "agent-service"
7config.set_resource_attribute("deployment.environment", "dev")
8
9subscriber = OpenTelemetrySubscriber(config)
10subscriber.register("otel-exporter")
11
12# Run instrumented application work here.
13
14subscriber.force_flush()
15subscriber.deregister("otel-exporter")
16subscriber.shutdown()

Common Configuration and Runtime Issues

  • transport is not http_binary or grpc.
  • Headers or resource attributes are not string-to-string maps.
  • The exporter feature is unavailable in the current build or target.
  • The endpoint is unreachable at runtime.