mirror of
https://github.com/open-telemetry/opentelemetry-python-contrib.git
synced 2025-07-29 21:23:55 +08:00
Change status codes from grpc status codes, remove setting status in instrumentations except on ERROR (#1282)
This commit is contained in:
@ -50,7 +50,7 @@ from opentelemetry import trace as trace_api
|
||||
from opentelemetry.instrumentation.dbapi.version import __version__
|
||||
from opentelemetry.instrumentation.utils import unwrap
|
||||
from opentelemetry.trace import SpanKind, TracerProvider, get_tracer
|
||||
from opentelemetry.trace.status import Status, StatusCanonicalCode
|
||||
from opentelemetry.trace.status import Status, StatusCode
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
@ -343,14 +343,10 @@ class TracedCursor:
|
||||
self._populate_span(span, *args)
|
||||
try:
|
||||
result = query_method(*args, **kwargs)
|
||||
if span.is_recording():
|
||||
span.set_status(Status(StatusCanonicalCode.OK))
|
||||
return result
|
||||
except Exception as ex: # pylint: disable=broad-except
|
||||
if span.is_recording():
|
||||
span.set_status(
|
||||
Status(StatusCanonicalCode.UNKNOWN, str(ex))
|
||||
)
|
||||
span.set_status(Status(StatusCode.ERROR, str(ex)))
|
||||
raise ex
|
||||
|
||||
|
||||
|
@ -65,8 +65,7 @@ class TestDBApiIntegration(TestBase):
|
||||
self.assertEqual(span.attributes["net.peer.name"], "testhost")
|
||||
self.assertEqual(span.attributes["net.peer.port"], 123)
|
||||
self.assertIs(
|
||||
span.status.canonical_code,
|
||||
trace_api.status.StatusCanonicalCode.OK,
|
||||
span.status.status_code, trace_api.status.StatusCode.UNSET,
|
||||
)
|
||||
|
||||
def test_span_not_recording(self):
|
||||
@ -117,8 +116,7 @@ class TestDBApiIntegration(TestBase):
|
||||
span = spans_list[0]
|
||||
self.assertEqual(span.attributes["db.statement"], "Test query")
|
||||
self.assertIs(
|
||||
span.status.canonical_code,
|
||||
trace_api.status.StatusCanonicalCode.UNKNOWN,
|
||||
span.status.status_code, trace_api.status.StatusCode.ERROR,
|
||||
)
|
||||
self.assertEqual(span.status.description, "Test Exception")
|
||||
|
||||
|
Reference in New Issue
Block a user