@@ -228,7 +228,7 @@ impl ErrorsIntakeUploader {
228
228
229
229
// Always try agent proxy (parallel to telemetry agent proxy)
230
230
let agent_url = format ! (
231
- "http://{}:{}/evp_proxy/v2 /api/v2/errorsintake" ,
231
+ "http://{}:{}/evp_proxy/v4 /api/v2/errorsintake" ,
232
232
agent_host, agent_port
233
233
) ;
234
234
eprintln ! ( "DEBUG: Sending to errors intake agent: {}" , agent_url) ;
@@ -240,20 +240,19 @@ impl ErrorsIntakeUploader {
240
240
241
241
// Try direct intake if conditions are met (parallel to telemetry direct)
242
242
if let Some ( api_key) = api_key {
243
- if direct_enabled {
244
- let site = parse_env:: str_not_empty ( "DD_SITE" )
245
- . unwrap_or_else ( || "datad0g.com" . to_string ( ) ) ;
246
- let direct_url =
247
- format ! ( "https://event-platform-intake.{}/api/v2/errorsintake" , site) ;
248
- eprintln ! ( "DEBUG: Sending to errors intake direct: {}" , direct_url) ;
249
-
250
- let direct_result = self
251
- . send_to_direct_intake ( & direct_url, & api_key, payload)
252
- . await ;
253
- if let Err ( e) = & direct_result {
254
- eprintln ! ( "Failed to send to errors intake direct: {}" , e) ;
255
- }
243
+ // if direct_enabled {
244
+ let site =
245
+ parse_env:: str_not_empty ( "DD_SITE" ) . unwrap_or_else ( || "datad0g.com" . to_string ( ) ) ;
246
+ let direct_url = format ! ( "https://event-platform-intake.{}/api/v2/errorsintake" , site) ;
247
+ eprintln ! ( "DEBUG: Sending to errors intake direct: {}" , direct_url) ;
248
+
249
+ let direct_result = self
250
+ . send_to_direct_intake ( & direct_url, & api_key, payload)
251
+ . await ;
252
+ if let Err ( e) = & direct_result {
253
+ eprintln ! ( "Failed to send to errors intake direct: {}" , e) ;
256
254
}
255
+ // }
257
256
}
258
257
259
258
// Return success regardless of individual failures (best effort)
0 commit comments