Skip to content

Commit a897a95

Browse files
committed
Update celery instrumentation to follow semantic conventions
1 parent 8c3bf3e commit a897a95

File tree

1 file changed

+5
-3
lines changed
  • instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery

1 file changed

+5
-3
lines changed

instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery/__init__.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,9 @@ def add(x, y):
7676
from opentelemetry.metrics import get_meter
7777
from opentelemetry.propagate import extract, inject
7878
from opentelemetry.propagators.textmap import Getter
79-
from opentelemetry.semconv.trace import SpanAttributes
79+
from opentelemetry.semconv._incubating.attributes import (
80+
messaging_attributes as SpanAttributes,
81+
)
8082
from opentelemetry.trace.status import Status, StatusCode
8183

8284
if VERSION >= (4, 0, 1):
@@ -128,15 +130,15 @@ def _instrument(self, **kwargs):
128130
__name__,
129131
__version__,
130132
tracer_provider,
131-
schema_url="https://opentelemetry.io/schemas/1.11.0",
133+
schema_url="https://opentelemetry.io/schemas/1.35.0",
132134
)
133135

134136
meter_provider = kwargs.get("meter_provider")
135137
meter = get_meter(
136138
__name__,
137139
__version__,
138140
meter_provider,
139-
schema_url="https://opentelemetry.io/schemas/1.11.0",
141+
schema_url="https://opentelemetry.io/schemas/1.35.0",
140142
)
141143

142144
self.create_celery_metrics(meter)

0 commit comments

Comments
 (0)