feat: add uninstrument

Author: ben-natan

instrumentation/opentelemetry-instrumentation-remoulade/setup.cfg

@@ -43,7 +43,6 @@ install_requires =
     opentelemetry-api ~= 1.3
     opentelemetry-semantic-conventions == 0.30b0
     opentelemetry-instrumentation == 0.30b0
-    wrapt >= 1.12.1
 
 [options.extras_require]
 test =
@@ -55,4 +54,4 @@ where = src
 
 [options.entry_points]
 opentelemetry_instrumentor =
-    redis = opentelemetry.instrumentation.remoulade:RemouladeInstrumentor
+    remoulade = opentelemetry.instrumentation.remoulade:RemouladeInstrumentor

instrumentation/opentelemetry-instrumentation-remoulade/src/opentelemetry/instrumentation/remoulade/__init__.py

@@ -104,6 +104,4 @@ def _instrument(self, **kwargs):
         broker.get_broker().add_middleware(instrumentation_middleware)
 
     def _uninstrument(self, **kwargs):
-        # Wait for remoulade==0.49.0 release
-        # broker.get_broker().remove_middleware(InstrumentationMiddleware)
-        return
+        broker.get_broker().remove_middleware(InstrumentationMiddleware)

instrumentation/opentelemetry-instrumentation-remoulade/src/opentelemetry/instrumentation/remoulade/package.py

@@ -13,4 +13,4 @@
 # limitations under the License.
 
 
-_instruments = ("remoulade >= 0.48",)
+_instruments = ("remoulade >= 0.49",)

instrumentation/opentelemetry-instrumentation-remoulade/tests/remoulade_test_messages.py

@@ -3,7 +3,6 @@
 from opentelemetry.instrumentation.remoulade import RemouladeInstrumentor
 from opentelemetry.test.test_base import TestBase
 from opentelemetry.trace import SpanKind
-from opentelemetry.semconv.trace import SpanAttributes
 
 
 @remoulade.actor(max_retries=3)
@@ -36,7 +35,7 @@ def test_message(self):
             consumer,
             {
                 "remoulade.action": "run",
-                "remoulade.actor_name": "actor_multiply",
+                "remoulade.actor_name": "actor_div",
             },
         )
 
@@ -46,7 +45,7 @@ def test_message(self):
             producer,
             {
                 "remoulade.action": "send",
-                "remoulade.actor_name": "actor_multiply",
+                "remoulade.actor_name": "actor_div",
             },
         )
 
@@ -69,7 +68,7 @@ def test_retries(self):
         self.assertEqual(consumer_spans[0].name, "remoulade/process(retry-3)")
         self.assertSpanHasAttributes(
             consumer_spans[0],
-            { "retry_count": 3 }
+            {"retry_count": 3}
         )
         self.assertEqual(consumer_spans[1].name, "remoulade/process(retry-2)")
         self.assertSpanHasAttributes(