Skip to content

Commit e03a397

Browse files
committed
Fix otel tests
1 parent 9299e0e commit e03a397

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

test_elasticsearch/test_otel.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -112,11 +112,11 @@ def test_forward_otel_context_to_subthreads(
112112
):
113113
tracer, memory_exporter = setup_tracing()
114114
es_client = Elasticsearch("http://localhost:9200")
115-
es_client._otel = OpenTelemetry(enabled=True, tracer=tracer)
115+
es_client._base_client._otel = OpenTelemetry(enabled=True, tracer=tracer)
116116

117117
_call_bulk_mock.return_value = mock.Mock()
118118
actions = ({"x": i} for i in range(100))
119119
list(helpers.parallel_bulk(es_client, actions, chunk_size=4))
120120
# Ensures that the OTEL context has been forwarded to all chunks
121-
assert es_client._otel.helpers_span.call_count == 1
122-
assert es_client._otel.use_span.call_count == 25
121+
assert es_client._base_client._otel.helpers_span.call_count == 1
122+
assert es_client._base_client._otel.use_span.call_count == 25

test_elasticsearch/test_server/test_otel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ def test_otel_bulk(sync_client, elasticsearch_url, bulk_helper_name):
6161

6262
# Create a new client with our tracer
6363
sync_client = sync_client.options()
64-
sync_client._otel.tracer = tracer
64+
sync_client._base_client._otel.tracer = tracer
6565
# "Disable" options to keep our custom tracer
6666
sync_client.options = lambda: sync_client
6767

0 commit comments

Comments
 (0)