fix(pika): use ObjectProxy for ReadyMessagesDequeProxy to restore iterability with wrapt 2.x (#4461)

* use ObjectProxy for pika ReadyMessagesDequeProxy to restore iterability

wrapt 2.x BaseObjectProxy does not proxy __iter__, breaking iteration
over the wrapped deque. Switch to ObjectProxy which proxies all dunder
methods including __iter__.

Assisted-by: Claude Opus 4.6

* update changelog with PR number

Assisted-by: Claude Opus 4.6

* fix lint: import ordering and formatting

Assisted-by: Claude Opus 4.6

Author: MikeGoldsmith

CHANGELOG.md

@@ -16,6 +16,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Bump `pylint` to `4.0.5`
   ([#4244](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4244))
 
+### Fixed
+
+- `opentelemetry-instrumentation-pika` Use `ObjectProxy` instead of `BaseObjectProxy` for `ReadyMessagesDequeProxy` to restore iterability with wrapt 2.x
+  ([#4461](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4461))
+
 ### Breaking changes
 
 - Drop Python 3.9 support

instrumentation/opentelemetry-instrumentation-pika/src/opentelemetry/instrumentation/pika/utils.py

@@ -7,12 +7,7 @@
 )
 from pika.channel import Channel
 from pika.spec import Basic, BasicProperties
-
-try:
-    # wrapt 2.0.0+
-    from wrapt import BaseObjectProxy  # pylint: disable=no-name-in-module
-except ImportError:
-    from wrapt import ObjectProxy as BaseObjectProxy
+from wrapt import ObjectProxy
 
 from opentelemetry import context, propagate, trace
 from opentelemetry.instrumentation.utils import is_instrumentation_enabled
@@ -201,7 +196,7 @@ def _enrich_span(
 
 
 # pylint:disable=abstract-method
-class ReadyMessagesDequeProxy(BaseObjectProxy):
+class ReadyMessagesDequeProxy(ObjectProxy):
     def __init__(
         self,
         wrapped,

instrumentation/opentelemetry-instrumentation-pika/tests/test_utils.py

@@ -568,3 +568,12 @@ def test_decorate_deque_proxy(
         get_span.assert_not_called()
         consume_hook.assert_not_called()
         returned_span.end.assert_not_called()
+
+    def test_deque_proxy_is_iterable(self) -> None:
+        deque = collections.deque([1, 2, 3])
+        generator_info = mock.MagicMock(
+            spec=_QueueConsumerGeneratorInfo,
+            consumer_tag="mock_task_name",
+        )
+        proxy = utils.ReadyMessagesDequeProxy(deque, generator_info, None)
+        self.assertEqual(list(proxy), [1, 2, 3])