This is a separate option that can be given to apply_async and needs to stay

Author: antonpirker

sentry_sdk/integrations/celery/__init__.py

@@ -254,6 +254,10 @@ def apply_async(*args, **kwargs):
             return f(*args, **kwargs)
 
         kwarg_headers = kwargs.get("headers") or {}
+        propagate_traces = kwarg_headers.pop("sentry-propagate-traces", True)
+
+        if not propagate_traces:
+            return f(*args, **kwargs)
 
         if isinstance(args[0], Task):
             task_name = args[0].name  # type: str