From 95973ccdac4a8d256b691ca91911b52c4a3e327c Mon Sep 17 00:00:00 2001 From: Divyanshi Date: Tue, 15 Apr 2025 15:02:53 -0700 Subject: [PATCH 1/2] Rename Otelcollector to otlp --- docs/source/concepts/observability.md | 2 +- src/aiq/observability/register.py | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) 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..94080c21 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 service.""" 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 From 5764f988c2b664e2bb141c22e9f99f90f0d52b62 Mon Sep 17 00:00:00 2001 From: Divyanshi Date: Tue, 15 Apr 2025 15:28:05 -0700 Subject: [PATCH 2/2] Signed-off-by: Author Name Update --- src/aiq/observability/register.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/aiq/observability/register.py b/src/aiq/observability/register.py index 94080c21..3d5a617f 100644 --- a/src/aiq/observability/register.py +++ b/src/aiq/observability/register.py @@ -48,7 +48,7 @@ async def phoenix_telemetry_exporter(config: PhoenixTelemetryExporter, builder: class OtlpTelemetryExporter(TelemetryExporterBaseConfig, name="otlp"): - """A telemetry exporter to transmit traces to externally hosted otlp service.""" + """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.")