i/Aether
1
0
Fork 0
mirror of https://github.com/fawney19/Aether.git synced 2026-09-13 14:40:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Record exhausted usage failures synchronously

Browse Source
This commit is contained in:
elky
2026-07-02 16:08:04 +08:00
parent ac93851b2a
commit 2f1cdb6a0b
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/aether-gateway/src/executor/outcome.rs
+14 -8
View File
@@ -342,10 +342,13 @@ pub(crate) async fn record_failed_usage_for_exhausted_request(
); );
data.request_metadata = Some(Value::Object(request_metadata)); data.request_metadata = Some(Value::Object(request_metadata));
state.usage_runtime.submit_terminal_event( state
state.data.as_ref(), .usage_runtime
UsageEvent::new(UsageEventType::Failed, request_id, data), .record_terminal_event_direct(
); state.data.as_ref(),
UsageEvent::new(UsageEventType::Failed, request_id, data),
)
.await;
} }
pub(crate) async fn record_failed_usage_for_runtime_miss_request( pub(crate) async fn record_failed_usage_for_runtime_miss_request(
@@ -478,10 +481,13 @@ pub(crate) async fn record_failed_usage_for_runtime_miss_request(
data.request_metadata = data.request_metadata =
(!request_metadata.is_empty()).then_some(Value::Object(request_metadata)); (!request_metadata.is_empty()).then_some(Value::Object(request_metadata));
state.usage_runtime.submit_terminal_event( state
state.data.as_ref(), .usage_runtime
UsageEvent::new(UsageEventType::Failed, request_id, data), .record_terminal_event_direct(
); state.data.as_ref(),
UsageEvent::new(UsageEventType::Failed, request_id, data),
)
.await;
} }
pub(crate) fn beautify_local_execution_client_error_message(message: &str) -> String { pub(crate) fn beautify_local_execution_client_error_message(message: &str) -> String {