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

chore: format merged PR changes

Browse Source
This commit is contained in:
fawney19
2026-05-19 08:13:56 +08:00
parent d216a9e219
commit d8a9d7eb5e
5 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apps/aether-gateway/src/ai_serving/planner/standard/openai/mod.rs
View File

@@ -1,6 +1,6 @@
mod chat; mod chat;
mod image_intent;
mod embedding; mod embedding;
mod image_intent;
mod responses; mod responses;
pub(crate) use crate::ai_serving::{ pub(crate) use crate::ai_serving::{
@@ -16,8 +16,8 @@ pub(crate) use chat::{
maybe_build_stream_local_decision_payload, maybe_build_sync_local_decision_payload, maybe_build_stream_local_decision_payload, maybe_build_sync_local_decision_payload,
set_local_openai_chat_execution_exhausted_diagnostic, set_local_openai_chat_execution_exhausted_diagnostic,
}; };
pub(super) use image_intent::openai_request_is_image_generation_intent;
pub(crate) use embedding::maybe_build_sync_local_openai_embedding_decision_payload; pub(crate) use embedding::maybe_build_sync_local_openai_embedding_decision_payload;
pub(super) use image_intent::openai_request_is_image_generation_intent;
pub(crate) use responses::{ pub(crate) use responses::{
build_local_openai_responses_stream_attempt_source_for_kind, build_local_openai_responses_stream_attempt_source_for_kind,
build_local_openai_responses_stream_plan_and_reports_for_kind, build_local_openai_responses_stream_plan_and_reports_for_kind,

5
apps/aether-gateway/src/ai_serving/transport.rs
View File

@@ -95,7 +95,6 @@ pub(crate) use aether_provider_transport::{
SameFormatProviderRequestBehaviorParams, SameFormatProviderRequestBodyInput, SameFormatProviderRequestBehaviorParams, SameFormatProviderRequestBodyInput,
SameFormatProviderUpstreamUrlParams, StandardPlanFallbackAcceptPolicy, SameFormatProviderUpstreamUrlParams, StandardPlanFallbackAcceptPolicy,
StandardPlanFallbackHeadersInput, StandardProviderRequestHeaders, StandardPlanFallbackHeadersInput, StandardProviderRequestHeaders,
StandardProviderRequestHeadersInput, TransportRequestUrlParams, GROK_CHAT_PATH, StandardProviderRequestHeadersInput, TransportRequestBodySemanticsError,
GROK_INTERNAL_HEADER, GROK_RATE_LIMITS_PATH, TransportRequestUrlParams, GROK_CHAT_PATH, GROK_INTERNAL_HEADER, GROK_RATE_LIMITS_PATH,
TransportRequestBodySemanticsError,
}; };

5
apps/aether-gateway/src/executor/outcome.rs
View File

@@ -1053,7 +1053,10 @@ fn insert_runtime_miss_diagnostic_metadata(
runtime_miss.insert("skip_reasons".to_string(), json!(diagnostic.skip_reasons)); runtime_miss.insert("skip_reasons".to_string(), json!(diagnostic.skip_reasons));
} }
if let Some(requested_model) = trimmed_non_empty(diagnostic.requested_model.as_deref()) { if let Some(requested_model) = trimmed_non_empty(diagnostic.requested_model.as_deref()) {
runtime_miss.insert("requested_model".to_string(), Value::String(requested_model)); runtime_miss.insert(
"requested_model".to_string(),
Value::String(requested_model),
);
} }
let mut provider_hint = Map::new(); let mut provider_hint = Map::new();

5
crates/aether-admin/src/observability/usage.rs
View File

@@ -3356,7 +3356,10 @@ mod tests {
"gemma-4-31b-it" "gemma-4-31b-it"
); );
assert_eq!(payload["scheduling_failure"]["candidate_count"], 1); assert_eq!(payload["scheduling_failure"]["candidate_count"], 1);
assert_eq!(payload["scheduling_failure"]["persisted_candidate_count"], 0); assert_eq!(
payload["scheduling_failure"]["persisted_candidate_count"],
0
);
assert_eq!(payload["scheduling_failure"]["skipped_candidate_count"], 1); assert_eq!(payload["scheduling_failure"]["skipped_candidate_count"], 1);
assert_eq!( assert_eq!(
payload["scheduling_failure"]["skip_reasons"]["provider_quota_blocked"], payload["scheduling_failure"]["skip_reasons"]["provider_quota_blocked"],

5
crates/aether-data/src/repository/candidate_selection/postgres.rs
View File

@@ -1316,9 +1316,8 @@ mod tests {
] { ] {
assert!(sql.contains("LOWER(BTRIM(p.provider_type)) = 'grok'")); assert!(sql.contains("LOWER(BTRIM(p.provider_type)) = 'grok'"));
assert!(sql.contains("LOWER(BTRIM(pak.auth_type)) = 'oauth'")); assert!(sql.contains("LOWER(BTRIM(pak.auth_type)) = 'oauth'"));
assert!( assert!(sql
sql.contains("'openai:chat', 'openai:responses', 'claude:messages', 'openai:image'") .contains("'openai:chat', 'openai:responses', 'claude:messages', 'openai:image'"));
);
assert!(sql.contains("'grok',")); assert!(sql.contains("'grok',"));
} }
} }