chore(dynamic-sampling): quiet redis noise in schedule_project_config

src/sentry/tasks/relay.py

@@ -10,6 +10,7 @@
 from sentry.tasks.base import instrumented_task
 from sentry.taskworker.namespaces import relay_tasks
 from sentry.utils import metrics
+from sentry.utils.exceptions import quiet_redis_noise
 from sentry.utils.sdk import set_current_event_project
 
 logger = logging.getLogger(__name__)
@@ -366,35 +367,36 @@ def _schedule_invalidate_project_config(
         else:
             check_debounce_keys["organization_id"] = org_id
 
-    if projectconfig_debounce_cache.invalidation.is_debounced(**check_debounce_keys):
-        # If this task is already in the queue, do not schedule another task.
+    with quiet_redis_noise():
+        if projectconfig_debounce_cache.invalidation.is_debounced(**check_debounce_keys):
+            # If this task is already in the queue, do not schedule another task.
+            metrics.incr(
+                "relay.projectconfig_cache.skipped",
+                tags={"reason": "debounce", "update_reason": trigger, "task": "invalidation"},
+            )
+            return
+
         metrics.incr(
-            "relay.projectconfig_cache.skipped",
-            tags={"reason": "debounce", "update_reason": trigger, "task": "invalidation"},
+            "relay.projectconfig_cache.scheduled",
+            tags={
+                "update_reason": trigger,
+                "update_reason_details": trigger_details,
+                "task": "invalidation",
+            },
         )
-        return
-
-    metrics.incr(
-        "relay.projectconfig_cache.scheduled",
-        tags={
-            "update_reason": trigger,
-            "update_reason_details": trigger_details,
-            "task": "invalidation",
-        },
-    )
 
-    invalidate_project_config.apply_async(
-        countdown=countdown,
-        kwargs={
-            "project_id": project_id,
-            "organization_id": organization_id,
-            "public_key": public_key,
-            "trigger": trigger,
-            "trigger_details": trigger_details,
-        },
-    )
+        invalidate_project_config.apply_async(
+            countdown=countdown,
+            kwargs={
+                "project_id": project_id,
+                "organization_id": organization_id,
+                "public_key": public_key,
+                "trigger": trigger,
+                "trigger_details": trigger_details,
+            },
+        )
 
-    # Use the original arguments to this function to set the debounce key.
-    projectconfig_debounce_cache.invalidation.debounce(
-        organization_id=organization_id, project_id=project_id, public_key=public_key
-    )
+        # Use the original arguments to this function to set the debounce key.
+        projectconfig_debounce_cache.invalidation.debounce(
+            organization_id=organization_id, project_id=project_id, public_key=public_key
+        )

src/sentry/workflow_engine/utils/exception_grouping.py → src/sentry/utils/exceptions.py

@@ -1,7 +1,7 @@
 import logging
 from collections.abc import Generator, Mapping
 from contextlib import contextmanager
-from typing import Any
+from typing import Any, Literal
 
 import sentry_sdk
 
@@ -10,11 +10,41 @@
 
 logger = logging.getLogger(__name__)
 
-
 # sentry_sdk doesn't export these.
 _Event = Any
 _ExcInfo = Any
 
+SentryLevel = Literal["error", "warning", "info"]
+
+
+@contextmanager
+def set_sentry_exception_levels(
+    exception_levels: dict[type[BaseException], SentryLevel],
+) -> Generator[None]:
+    """
+    Context manager that sets up a Sentry error processor to set
+    specific exception types to configured Sentry levels.
+
+    Args:
+        exception_levels: Map of exception type to their desired Sentry levels
+        Note that type matching is done by equality, not isinstance.
+    """
+
+    def process_error(event: _Event, exc_info: _ExcInfo) -> _Event | None:
+        exc = exc_info[1]
+        exc_type = type(exc)
+
+        # Check if this exception type should have its level overridden
+        if exc_type in exception_levels:
+            new_level = exception_levels[exc_type]
+            event["level"] = new_level
+
+        return event
+
+    with sentry_sdk.new_scope() as scope:
+        scope.add_error_processor(process_error)
+        yield
+
 
 @contextmanager
 def exception_grouping_context(
@@ -65,3 +95,24 @@ def timeout_grouping_context(*refinements: str) -> Generator[None]:
         {ProcessingDeadlineExceeded: "task.processing_deadline_exceeded"}, *refinements
     ):
         yield
+
+
+@contextmanager
+def quiet_redis_noise() -> Generator[None]:
+    """
+    Context manager that sets up a Sentry error processor to quiet Redis noise.
+    Specifically, the current library versions report TimeoutError and MovedError
+    internally even when they're being appropriately handled, and it's incorrect for
+    those to be treated as errors in Sentry.
+    """
+    from redis.exceptions import TimeoutError
+    from rediscluster.exceptions import (  # type: ignore[attr-defined]
+        MovedError,
+        RedisClusterException,
+    )
+
+    with (
+        exception_grouping_context({RedisClusterException: "redis.redis_cluster_exception"}),
+        set_sentry_exception_levels({TimeoutError: "info", MovedError: "info"}),
+    ):
+        yield

src/sentry/workflow_engine/tasks/actions.py

@@ -10,13 +10,14 @@
 from sentry.taskworker import namespaces
 from sentry.taskworker.retry import Retry
 from sentry.utils import metrics
+from sentry.utils.exceptions import timeout_grouping_context
 from sentry.workflow_engine.models import Action, Detector
 from sentry.workflow_engine.tasks.utils import (
     build_workflow_event_data_from_activity,
     build_workflow_event_data_from_event,
 )
 from sentry.workflow_engine.types import WorkflowEventData
-from sentry.workflow_engine.utils import log_context, timeout_grouping_context
+from sentry.workflow_engine.utils import log_context
 
 logger = log_context.get_logger(__name__)
 

src/sentry/workflow_engine/tasks/delayed_workflows.py

@@ -6,8 +6,8 @@
 from sentry.tasks.base import instrumented_task, retry
 from sentry.taskworker.namespaces import workflow_engine_tasks
 from sentry.taskworker.retry import Retry
+from sentry.utils.exceptions import quiet_redis_noise
 from sentry.workflow_engine.utils import log_context
-from sentry.workflow_engine.utils.sentry_level_utils import quiet_redis_noise
 
 logger = log_context.get_logger("sentry.workflow_engine.tasks.delayed_workflows")
 

src/sentry/workflow_engine/tasks/workflows.py

@@ -15,6 +15,7 @@
 from sentry.taskworker import namespaces
 from sentry.taskworker.retry import Retry, retry_task
 from sentry.utils import metrics
+from sentry.utils.exceptions import quiet_redis_noise
 from sentry.utils.locking import UnableToAcquireLock
 from sentry.workflow_engine.models import Detector
 from sentry.workflow_engine.tasks.utils import (
@@ -23,7 +24,6 @@
 )
 from sentry.workflow_engine.types import WorkflowEventData
 from sentry.workflow_engine.utils import log_context, scopedstats
-from sentry.workflow_engine.utils.sentry_level_utils import quiet_redis_noise
 
 logger = log_context.get_logger(__name__)
 

src/sentry/workflow_engine/utils/__init__.py

@@ -1,8 +1,6 @@
 __all__ = [
     "metrics_incr",
     "MetricTags",
-    "timeout_grouping_context",
 ]
 
-from .exception_grouping import timeout_grouping_context
 from .metrics import MetricTags, metrics_incr