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<UsageData>) {
                         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<UsageData>) {
                     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);
     }
 }