opensource/opentelemetry-python-contrib
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-python-contrib.git synced 2025-08-03 04:10:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

Upgrade black (#802)

Browse Source
This commit is contained in:
Owais Lone
2021-11-11 02:27:01 +05:30
committed by GitHub
parent f4d09f956a
commit 3137c1fa41
70 changed files with 352 additions and 147 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
instrumentation/opentelemetry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/__init__.py
View File

@ -119,7 +119,8 @@ class ElasticsearchInstrumentor(BaseInstrumentor):
def __init__(self, span_name_prefix=None):
if not span_name_prefix:
span_name_prefix = environ.get(
"OTEL_PYTHON_ELASTICSEARCH_NAME_PREFIX", "Elasticsearch",
"OTEL_PYTHON_ELASTICSEARCH_NAME_PREFIX",
"Elasticsearch",
)
self._span_name_prefix = span_name_prefix.strip()
super().__init__()
@ -187,7 +188,8 @@ def _wrap_perform_request(
body = kwargs.get("body", None)
with tracer.start_as_current_span(
op_name, kind=SpanKind.CLIENT,
op_name,
kind=SpanKind.CLIENT,
) as span:
if callable(request_hook):
@ -215,7 +217,8 @@ def _wrap_perform_request(
for member in _ATTRIBUTES_FROM_RESULT:
if member in rv:
span.set_attribute(
f"elasticsearch.{member}", str(rv[member]),
f"elasticsearch.{member}",
str(rv[member]),
)
if callable(response_hook):