feat(integrations): Start new trace on retrying

- Start new trace in case of retrying task. Such decision makes life
easier to investigate failed transactions in complicated traces.
- also fix logging issue in tests

Issue: #3454

Author: igorek

sentry_sdk/integrations/dramatiq.py

@@ -127,8 +127,13 @@ def before_process_message(self, broker, message):
         scope.clear_breadcrumbs()
         scope.add_event_processor(_make_message_event_processor(message, integration))
 
+        sentry_headers = message.options.get("sentry_headers") or {}
+        if "retries" in message.options:
+            # start new trace in case of retrying
+            sentry_headers = {}
+
         transaction = continue_trace(
-            message.options.get("sentry_headers") or {},
+            sentry_headers,
             name=message.actor_name,
             op=OP.QUEUE_TASK_DRAMATIQ,
             source=TransactionSource.TASK,

tests/integrations/dramatiq/test_dramatiq.py

@@ -9,16 +9,16 @@
 from sentry_sdk import start_transaction
 from sentry_sdk.consts import SPANSTATUS
 from sentry_sdk.integrations.dramatiq import DramatiqIntegration
+from sentry_sdk.integrations.logging import ignore_logger
 
-# from sentry_sdk.integrations.logging import LoggingIntegration
+ignore_logger("dramatiq.worker.WorkerThread")
 
 
 @pytest.fixture(scope="function")
 def broker(request, sentry_init):
     sentry_init(
         integrations=[DramatiqIntegration()],
         traces_sample_rate=getattr(request, "param", None),
-        # disabled_integrations=[LoggingIntegration()],
     )
     broker = StubBroker()
     broker.emit_after("process_boot")
@@ -78,8 +78,7 @@ def dummy_actor(x, y):
         error_event = events.pop(0)
         exception = error_event["exception"]["values"][0]
         assert exception["type"] == "ZeroDivisionError"
-        # todo: failed assert. Logging instead of dramatiq
-        # assert exception["mechanism"]["type"] == DramatiqIntegration.identifier
+        assert exception["mechanism"]["type"] == DramatiqIntegration.identifier
 
     (event,) = events
     assert event["type"] == "transaction"