diff --git a/docs/source/concepts/observability.md b/docs/source/concepts/observability.md index c050cddc..57f19285 100644 --- a/docs/source/concepts/observability.md +++ b/docs/source/concepts/observability.md @@ -20,7 +20,7 @@ limitations under the License. The AgentIQ Observability Module provides support for configurable telemetry setup to do logging tracing and metrics for AgentIQ workflows. - Enables users to configure telemetry options from a predefined list based on their preferences. - Listens real-time usage statistics pushed by `IntermediateStepManager`. -- Translates the usage statistics to OpenTelemetry format and push to the configured provider/method. (e.g., phoenix, OTelCollector, console, file) +- Translates the usage statistics to OpenTelemetry format and push to the configured provider/method. (e.g., phoenix, otlp, console, file) These features enable AgentIQ developers to test their workflows locally and integrate observability seamlessly. diff --git a/src/aiq/observability/register.py b/src/aiq/observability/register.py index 4d068da6..3d5a617f 100644 --- a/src/aiq/observability/register.py +++ b/src/aiq/observability/register.py @@ -47,15 +47,15 @@ async def phoenix_telemetry_exporter(config: PhoenixTelemetryExporter, builder: logger.error("Error in Phoenix telemetry Exporter\n %s", ex, exc_info=True) -class OtelCollectorTelemetryExporter(TelemetryExporterBaseConfig, name="otelcollector"): - """A telemetry exporter to transmit traces to externally hosted otel collector service.""" +class OtlpTelemetryExporter(TelemetryExporterBaseConfig, name="otlp"): + """A telemetry exporter to transmit traces to externally hosted otlp services.""" endpoint: str = Field(description="The otel endpoint to export telemetry traces.") project: str = Field(description="The project name to group the telemetry traces.") -@register_telemetry_exporter(config_type=OtelCollectorTelemetryExporter) -async def otel_telemetry_exporter(config: OtelCollectorTelemetryExporter, builder: Builder): +@register_telemetry_exporter(config_type=OtlpTelemetryExporter) +async def otlp_telemetry_exporter(config: OtlpTelemetryExporter, builder: Builder): from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter