fix(debugger): retry writes when any error occurs

ddtrace/debugging/_uploader.py

@@ -154,9 +154,8 @@ def _write(self, payload: bytes, endpoint: str) -> None:
                 if not (200 <= resp.status < 300):
                     log.error("Failed to upload payload to endpoint %s: [%d] %r", endpoint, resp.status, resp.read())
                     meter.increment("upload.error", tags={"status": str(resp.status)})
-                    if 400 <= resp.status < 500:
-                        msg = "Failed to upload payload"
-                        raise SignalUploaderError(msg)
+                    msg = "Failed to upload payload"
+                    raise SignalUploaderError(msg)
                 else:
                     meter.increment("upload.success")
                     meter.distribution("upload.size", len(payload))

releasenotes/notes/fix-debugger-write-retries-e097ff1f0836531b.yaml

@@ -0,0 +1,4 @@
+---
+fixes:
+  - |
+    dynamic instrumentation: uploading snapshots now retries on all HTTP error codes.

tests/debugging/test_uploader.py

@@ -70,3 +70,35 @@ def test_uploader_full_buffer():
         # wakeup to mimic next interval
         uploader.periodic()
         assert uploader.queue.qsize() == 0
+
+
+def test_uploader_502_error():
+    """Test that _write raises SignalUploaderError for 502 Bad Gateway errors."""
+    from ddtrace.debugging._uploader import SignalUploader
+    from ddtrace.debugging._uploader import SignalUploaderError
+
+    class MockResponse:
+        status = 502
+
+        def read(self):
+            return b"Bad Gateway"
+
+    class MockConnection:
+        def __enter__(self):
+            return self
+
+        def __exit__(self, *args):
+            pass
+
+        def request(self, *args, **kwargs):
+            pass
+
+        def getresponse(self):
+            return MockResponse()
+
+    uploader = SignalUploader(interval=LONG_INTERVAL)
+    uploader._connect = lambda: MockConnection()
+
+    # Assert that 502 errors raise SignalUploaderError
+    with pytest.raises(SignalUploaderError):
+        uploader._write(b'{"test": "data"}', "/debugger/v1/input")