fix(spotlight): align behavior with SDK spec

sentry_sdk/client.py

@@ -360,6 +360,8 @@ def _init_impl(self):
 
         def _capture_envelope(envelope):
             # type: (Envelope) -> None
+            if self.spotlight is not None:
+                self.spotlight.capture_envelope(envelope)
             if self.transport is not None:
                 self.transport.capture_envelope(envelope)
 
@@ -387,6 +389,18 @@ def _record_lost_event(
                 if self.options["enable_backpressure_handling"]:
                     self.monitor = Monitor(self.transport)
 
+            # Setup Spotlight before creating batchers so _capture_envelope can use it.
+            # setup_spotlight handles all config/env var resolution per the SDK spec.
+            from sentry_sdk.spotlight import setup_spotlight
+
+            self.spotlight = setup_spotlight(self.options)
+            if self.spotlight is not None and not self.options["dsn"]:
+                sample_all = lambda *_args, **_kwargs: 1.0
+                self.options["send_default_pii"] = True
+                self.options["error_sampler"] = sample_all
+                self.options["traces_sampler"] = sample_all
+                self.options["profiles_sampler"] = sample_all
+
             self.session_flusher = SessionFlusher(capture_func=_capture_envelope)
 
             self.log_batcher = None
@@ -437,29 +451,6 @@ def _record_lost_event(
                 options=self.options,
             )
 
-            spotlight_config = self.options.get("spotlight")
-            if spotlight_config is None and "SENTRY_SPOTLIGHT" in os.environ:
-                spotlight_env_value = os.environ["SENTRY_SPOTLIGHT"]
-                spotlight_config = env_to_bool(spotlight_env_value, strict=True)
-                self.options["spotlight"] = (
-                    spotlight_config
-                    if spotlight_config is not None
-                    else spotlight_env_value
-                )
-
-            if self.options.get("spotlight"):
-                # This is intentionally here to prevent setting up spotlight
-                # stuff we don't need unless spotlight is explicitly enabled
-                from sentry_sdk.spotlight import setup_spotlight
-
-                self.spotlight = setup_spotlight(self.options)
-                if not self.options["dsn"]:
-                    sample_all = lambda *_args, **_kwargs: 1.0
-                    self.options["send_default_pii"] = True
-                    self.options["error_sampler"] = sample_all
-                    self.options["traces_sampler"] = sample_all
-                    self.options["profiles_sampler"] = sample_all
-
             sdk_name = get_sdk_name(list(self.integrations.keys()))
             SDK_INFO["name"] = sdk_name
             logger.debug("Setting SDK name to '%s'", sdk_name)

sentry_sdk/spotlight.py

@@ -1,6 +1,7 @@
 import io
 import logging
 import os
+import time
 import urllib.parse
 import urllib.request
 import urllib.error
@@ -34,14 +35,37 @@
 
 
 class SpotlightClient:
+    """
+    A client for sending envelopes to Sentry Spotlight.
+
+    Implements exponential backoff retry logic per the SDK spec:
+    - Logs error at least once when server is unreachable
+    - Does not log for every failed envelope
+    - Uses exponential backoff to avoid hammering an unavailable server
+    - Never blocks normal Sentry operation
+    """
+
+    # Exponential backoff settings
+    INITIAL_RETRY_DELAY = 1.0  # Start with 1 second
+    MAX_RETRY_DELAY = 60.0  # Max 60 seconds
+
     def __init__(self, url):
         # type: (str) -> None
         self.url = url
         self.http = urllib3.PoolManager()
-        self.fails = 0
+        self._retry_delay = self.INITIAL_RETRY_DELAY
+        self._last_error_time = 0.0  # type: float
 
     def capture_envelope(self, envelope):
         # type: (Envelope) -> None
+
+        # Check if we're in backoff period - skip sending to avoid blocking
+        if self._last_error_time > 0:
+            time_since_error = time.time() - self._last_error_time
+            if time_since_error < self._retry_delay:
+                # Still in backoff period, skip this envelope
+                return
+
         body = io.BytesIO()
         envelope.serialize_into(body)
         try:
@@ -54,18 +78,23 @@ def capture_envelope(self, envelope):
                 },
             )
             req.close()
-            self.fails = 0
+            # Success - reset backoff state
+            self._retry_delay = self.INITIAL_RETRY_DELAY
+            self._last_error_time = 0.0
         except Exception as e:
-            if self.fails < 2:
-                sentry_logger.warning(str(e))
-                self.fails += 1
-            elif self.fails == 2:
-                self.fails += 1
-                sentry_logger.warning(
-                    "Looks like Spotlight is not running, will keep trying to send events but will not log errors."
-                )
-            # omitting self.fails += 1 in the `else:` case intentionally
-            # to avoid overflowing the variable if Spotlight never becomes reachable
+            self._last_error_time = time.time()
+
+            # Increase backoff delay exponentially first, so logged value matches actual wait
+            self._retry_delay = min(self._retry_delay * 2, self.MAX_RETRY_DELAY)
+
+            # Log error once per backoff cycle (we skip sends during backoff, so only one failure per cycle)
+            sentry_logger.warning(
+                "Failed to send envelope to Spotlight at %s: %s. "
+                "Will retry after %.1f seconds.",
+                self.url,
+                e,
+                self._retry_delay,
+            )
 
 
 try:
@@ -207,20 +236,83 @@ def process_exception(self, _request, exception):
     settings = None
 
 
+def _resolve_spotlight_url(spotlight_config, sentry_logger):
+    # type: (Any, Any) -> Optional[str]
+    """
+    Resolve the Spotlight URL based on config and environment variable.
+
+    Implements precedence rules per the SDK spec:
+    https://develop.sentry.dev/sdk/expected-features/spotlight/
+
+    Returns the resolved URL string, or None if Spotlight should be disabled.
+    """
+    spotlight_env_value = os.environ.get("SENTRY_SPOTLIGHT")
+
+    # Parse env var to determine if it's a boolean or URL
+    spotlight_from_env = None  # type: Optional[bool]
+    spotlight_env_url = None  # type: Optional[str]
+    if spotlight_env_value:
+        parsed = env_to_bool(spotlight_env_value, strict=True)
+        if parsed is None:
+            # It's a URL string
+            spotlight_from_env = True
+            spotlight_env_url = spotlight_env_value
+        else:
+            spotlight_from_env = parsed
+
+    # Apply precedence rules per spec:
+    # https://develop.sentry.dev/sdk/expected-features/spotlight/#precedence-rules
+    if spotlight_config is False:
+        # Config explicitly disables spotlight - warn if env var was set
+        if spotlight_from_env:
+            sentry_logger.warning(
+                "Spotlight is disabled via spotlight=False config option, "
+                "ignoring SENTRY_SPOTLIGHT environment variable."
+            )
+        return None
+    elif spotlight_config is True:
+        # Config enables spotlight with boolean true
+        # If env var has URL, use env var URL per spec
+        if spotlight_env_url:
+            return spotlight_env_url
+        else:
+            return DEFAULT_SPOTLIGHT_URL
+    elif isinstance(spotlight_config, str):
+        # Config has URL string - use config URL, warn if env var differs
+        if spotlight_env_value and spotlight_env_value != spotlight_config:
+            sentry_logger.warning(
+                "Spotlight URL from config (%s) takes precedence over "
+                "SENTRY_SPOTLIGHT environment variable (%s).",
+                spotlight_config,
+                spotlight_env_value,
+            )
+        return spotlight_config
+    elif spotlight_config is None:
+        # No config - use env var
+        if spotlight_env_url:
+            return spotlight_env_url
+        elif spotlight_from_env:
+            return DEFAULT_SPOTLIGHT_URL
+        # else: stays None (disabled)
+
+    return None
+
+
 def setup_spotlight(options):
     # type: (Dict[str, Any]) -> Optional[SpotlightClient]
+    url = _resolve_spotlight_url(options.get("spotlight"), sentry_logger)
+
+    if url is None:
+        return None
+
+    # Only set up logging handler when spotlight is actually enabled
     _handler = logging.StreamHandler(sys.stderr)
     _handler.setFormatter(logging.Formatter(" [spotlight] %(levelname)s: %(message)s"))
     logger.addHandler(_handler)
     logger.setLevel(logging.INFO)
 
-    url = options.get("spotlight")
-
-    if url is True:
-        url = DEFAULT_SPOTLIGHT_URL
-
-    if not isinstance(url, str):
-        return None
+    # Update options with resolved URL for consistency
+    options["spotlight"] = url
 
     with capture_internal_exceptions():
         if (

tests/test_client.py

@@ -1181,7 +1181,8 @@ def test_debug_option(
         (None, "t", DEFAULT_SPOTLIGHT_URL),
         (None, "1", DEFAULT_SPOTLIGHT_URL),
         (True, None, DEFAULT_SPOTLIGHT_URL),
-        (True, "http://localhost:8080/slurp", DEFAULT_SPOTLIGHT_URL),
+        # Per spec: spotlight=True + env URL -> use env URL
+        (True, "http://localhost:8080/slurp", "http://localhost:8080/slurp"),
         ("http://localhost:8080/slurp", "f", "http://localhost:8080/slurp"),
         (None, "http://localhost:8080/slurp", "http://localhost:8080/slurp"),
     ],

tests/test_spotlight.py

@@ -1,6 +1,7 @@
 import pytest
 
 import sentry_sdk
+from sentry_sdk.spotlight import DEFAULT_SPOTLIGHT_URL
 
 
 @pytest.fixture
@@ -54,3 +55,69 @@ def test_spotlight_envelope(sentry_init, capture_spotlight_envelopes):
     payload = envelope.items[0].payload.json
 
     assert payload["exception"]["values"][0]["value"] == "aha!"
+
+
+def test_spotlight_true_with_env_url_uses_env_url(sentry_init, monkeypatch):
+    """Per spec: spotlight=True + env URL -> use env URL"""
+    monkeypatch.setenv("SENTRY_SPOTLIGHT", "http://custom:9999/stream")
+    sentry_init(spotlight=True)
+
+    spotlight = sentry_sdk.get_client().spotlight
+    assert spotlight is not None
+    assert spotlight.url == "http://custom:9999/stream"
+
+
+def test_spotlight_false_ignores_env_var(sentry_init, monkeypatch, caplog):
+    """Per spec: spotlight=False ignores env var and logs warning"""
+    import logging
+
+    with caplog.at_level(logging.WARNING, logger="sentry_sdk.errors"):
+        monkeypatch.setenv("SENTRY_SPOTLIGHT", "true")
+        sentry_init(spotlight=False, debug=True)
+
+        assert sentry_sdk.get_client().spotlight is None
+        assert "ignoring SENTRY_SPOTLIGHT environment variable" in caplog.text
+
+
+def test_spotlight_config_url_overrides_env_url_with_warning(
+    sentry_init, monkeypatch, caplog
+):
+    """Per spec: config URL takes precedence over env URL with warning"""
+    import logging
+
+    with caplog.at_level(logging.WARNING, logger="sentry_sdk.errors"):
+        monkeypatch.setenv("SENTRY_SPOTLIGHT", "http://env:9999/stream")
+        sentry_init(spotlight="http://config:8888/stream", debug=True)
+
+        spotlight = sentry_sdk.get_client().spotlight
+        assert spotlight is not None
+        assert spotlight.url == "http://config:8888/stream"
+        assert "takes precedence over" in caplog.text
+
+
+def test_spotlight_config_url_same_as_env_no_warning(sentry_init, monkeypatch, caplog):
+    """No warning when config URL matches env URL"""
+    import logging
+
+    with caplog.at_level(logging.WARNING, logger="sentry_sdk.errors"):
+        monkeypatch.setenv("SENTRY_SPOTLIGHT", "http://same:9999/stream")
+        sentry_init(spotlight="http://same:9999/stream", debug=True)
+
+        spotlight = sentry_sdk.get_client().spotlight
+        assert spotlight is not None
+        assert spotlight.url == "http://same:9999/stream"
+        assert "takes precedence over" not in caplog.text
+
+
+def test_spotlight_receives_session_envelopes(sentry_init, capture_spotlight_envelopes):
+    """Spotlight should receive session envelopes, not just error events"""
+    sentry_init(spotlight=True, release="test-release")
+    envelopes = capture_spotlight_envelopes()
+
+    # Start and end a session
+    sentry_sdk.get_isolation_scope().start_session()
+    sentry_sdk.get_isolation_scope().end_session()
+    sentry_sdk.flush()
+
+    # Should have received at least one envelope with session data
+    assert len(envelopes) > 0