From beaeaee55b1ea521f59da0a89fe00e9979bbf257 Mon Sep 17 00:00:00 2001 From: Huaijin Date: Mon, 30 Mar 2026 14:30:34 +0800 Subject: [PATCH] fix: report to remote not blocking (#11053) --- src/service/self_reporting/ingestion.rs | 6 ++---- src/service/self_reporting/mod.rs | 2 +- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/src/service/self_reporting/ingestion.rs b/src/service/self_reporting/ingestion.rs index c5600bc3c1..dc30ce35b8 100644 --- a/src/service/self_reporting/ingestion.rs +++ b/src/service/self_reporting/ingestion.rs @@ -152,8 +152,7 @@ pub(super) async fn ingest_usages(mut curr_usages: Vec) { let curr_usages = curr_usages.clone(); for usage_data in curr_usages { if let Err(e) = super::queues::USAGE_QUEUE - .enqueue(ReportingData::Usage(Box::new(usage_data))) - .await + .try_enqueue(ReportingData::Usage(Box::new(usage_data))) { log::error!( "[SELF-REPORTING] Error in pushing back un-ingested Usage data to UsageQueuer: {e}" @@ -170,8 +169,7 @@ pub(super) async fn ingest_usages(mut curr_usages: Vec) { let curr_usages = curr_usages.clone(); for usage_data in curr_usages { if let Err(e) = super::queues::USAGE_QUEUE - .enqueue(ReportingData::Usage(Box::new(usage_data))) - .await + .try_enqueue(ReportingData::Usage(Box::new(usage_data))) { log::error!( "[SELF-REPORTING] Error in pushing back un-ingested Usage data to UsageQueuer: {e}" diff --git a/src/service/self_reporting/mod.rs b/src/service/self_reporting/mod.rs index 4c24295020..9e81e8b625 100644 --- a/src/service/self_reporting/mod.rs +++ b/src/service/self_reporting/mod.rs @@ -217,7 +217,7 @@ pub async fn report_request_usage_stats( peak_memory_usage: stats.peak_memory_usage, }); if !usage.is_empty() { - publish_usage(usage).await; + report_usage(usage); } }