Skip to content

Commit 4b85b7f

Browse files
Merge branch 'main' into fix-issue-2870
2 parents 3c103f9 + 6bb6d38 commit 4b85b7f

File tree

94 files changed

+598
-116
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

94 files changed

+598
-116
lines changed

Diff for: .github/component_owners.yml

+3
Original file line numberDiff line numberDiff line change
@@ -61,5 +61,8 @@ components:
6161
instrumentation/opentelemetry-instrumentation-psycopg:
6262
- federicobond
6363

64+
instrumentation/opentelemetry-instrumentation-aiokafka:
65+
- dimastbk
66+
6467
processor/opentelemetry-processor-baggage:
6568
- codeboten

Diff for: CHANGELOG.md

+10-1
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,15 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
1313
([#2860](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2860))
1414
- `opentelemetry-instrumentation-aiokafka` Add instrumentor and auto instrumentation support for aiokafka
1515
([#2082](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2082))
16+
- `opentelemetry-instrumentation-redis` Add additional attributes for methods create_index and search, rename those spans
17+
([#2635](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2635))
1618

17-
## Version 1.27.0/0.48b0 ()
19+
### Fixed
20+
21+
- `opentelemetry-instrumentation-aiokafka` Wrap `AIOKafkaConsumer.getone()` instead of `AIOKafkaConsumer.__anext__`
22+
([#2874](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2874))
23+
24+
## Version 1.27.0/0.48b0 (2024-08-28)
1825

1926
### Added
2027

@@ -23,6 +30,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
2330
([#2537](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2537))
2431
- `opentelemetry-instrumentation-asgi`, `opentelemetry-instrumentation-fastapi` Add ability to disable internal HTTP send and receive spans
2532
([#2802](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2802))
33+
- `opentelemetry-instrumentation-asgi` Add fallback decoding for ASGI headers
34+
([#2837](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2837))
2635

2736
### Breaking changes
2837

Diff for: exporter/opentelemetry-exporter-prometheus-remote-write/test-requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ pytest==7.4.4
1616
python-snappy==0.7.1
1717
requests==2.32.3
1818
tomli==2.0.1
19-
typing_extensions==4.10.0
19+
typing_extensions==4.12.2
2020
urllib3==2.2.2
2121
wrapt==1.16.0
2222
zipp==3.19.2

Diff for: exporter/opentelemetry-exporter-richconsole/test-requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ Pygments==2.17.2
1212
pytest==7.4.4
1313
rich==13.7.1
1414
tomli==2.0.1
15-
typing_extensions==4.10.0
15+
typing_extensions==4.12.2
1616
wrapt==1.16.0
1717
zipp==3.19.2
1818
-e exporter/opentelemetry-exporter-richconsole

Diff for: instrumentation/opentelemetry-instrumentation-aio-pika/test-requirements-0.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ pluggy==1.5.0
1212
py-cpuinfo==9.0.0
1313
pytest==7.4.4
1414
tomli==2.0.1
15-
typing_extensions==4.9.0
15+
typing_extensions==4.12.2
1616
wrapt==1.16.0
1717
yarl==1.9.4
1818
zipp==3.19.2

Diff for: instrumentation/opentelemetry-instrumentation-aio-pika/test-requirements-1.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ pluggy==1.5.0
1212
py-cpuinfo==9.0.0
1313
pytest==7.4.4
1414
tomli==2.0.1
15-
typing_extensions==4.9.0
15+
typing_extensions==4.12.2
1616
wrapt==1.16.0
1717
yarl==1.9.4
1818
zipp==3.19.2

Diff for: instrumentation/opentelemetry-instrumentation-aio-pika/test-requirements-2.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ pluggy==1.5.0
1212
py-cpuinfo==9.0.0
1313
pytest==7.4.4
1414
tomli==2.0.1
15-
typing_extensions==4.9.0
15+
typing_extensions==4.12.2
1616
wrapt==1.16.0
1717
yarl==1.9.4
1818
zipp==3.19.2

Diff for: instrumentation/opentelemetry-instrumentation-aio-pika/test-requirements-3.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ pluggy==1.5.0
1212
py-cpuinfo==9.0.0
1313
pytest==7.4.4
1414
tomli==2.0.1
15-
typing_extensions==4.9.0
15+
typing_extensions==4.12.2
1616
wrapt==1.16.0
1717
yarl==1.9.4
1818
zipp==3.19.2

Diff for: instrumentation/opentelemetry-instrumentation-aiohttp-client/test-requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ py-cpuinfo==9.0.0
2323
pytest==7.4.4
2424
requests==2.32.3
2525
tomli==2.0.1
26-
typing_extensions==4.10.0
26+
typing_extensions==4.12.2
2727
urllib3==2.2.2
2828
Werkzeug==3.0.3
2929
wrapt==1.16.0

Diff for: instrumentation/opentelemetry-instrumentation-aiohttp-server/test-requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ pytest==7.4.4
1515
pytest-aiohttp==1.0.5
1616
pytest-asyncio==0.23.5
1717
tomli==2.0.1
18-
typing_extensions==4.10.0
18+
typing_extensions==4.12.2
1919
wrapt==1.16.0
2020
yarl==1.9.4
2121
zipp==3.19.2

Diff for: instrumentation/opentelemetry-instrumentation-aiokafka/src/opentelemetry/instrumentation/aiokafka/__init__.py

+4-4
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ async def async_consume_hook(span, record, args, kwargs):
7676
from opentelemetry import trace
7777
from opentelemetry.instrumentation.aiokafka.package import _instruments
7878
from opentelemetry.instrumentation.aiokafka.utils import (
79-
_wrap_anext,
79+
_wrap_getone,
8080
_wrap_send,
8181
)
8282
from opentelemetry.instrumentation.aiokafka.version import __version__
@@ -126,10 +126,10 @@ def _instrument(self, **kwargs):
126126
)
127127
wrap_function_wrapper(
128128
aiokafka.AIOKafkaConsumer,
129-
"__anext__",
130-
_wrap_anext(tracer, async_consume_hook),
129+
"getone",
130+
_wrap_getone(tracer, async_consume_hook),
131131
)
132132

133133
def _uninstrument(self, **kwargs):
134134
unwrap(aiokafka.AIOKafkaProducer, "send")
135-
unwrap(aiokafka.AIOKafkaConsumer, "__anext__")
135+
unwrap(aiokafka.AIOKafkaConsumer, "getone")

Diff for: instrumentation/opentelemetry-instrumentation-aiokafka/src/opentelemetry/instrumentation/aiokafka/utils.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -335,7 +335,7 @@ async def _create_consumer_span(
335335
context.detach(token)
336336

337337

338-
def _wrap_anext(
338+
def _wrap_getone(
339339
tracer: Tracer, async_consume_hook: ConsumeHookT
340340
) -> Callable[..., Awaitable[aiokafka.ConsumerRecord]]:
341341
async def _traced_next(

0 commit comments

Comments
 (0)