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

Fix pool score CI regressions

Browse Source
This commit is contained in:
fawney19
2026-05-12 02:17:19 +08:00
parent b9e62d1667
commit c578689356
5 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apps/aether-gateway/src/ai_serving/planner/pool_scores.rs
View File

@@ -172,8 +172,8 @@ fn json_f64(value: &Value) -> Option<f64> {
} }
fn api_format_lookup_keys(api_format: &str) -> Vec<String> { fn api_format_lookup_keys(api_format: &str) -> Vec<String> {
let normalized = aether_ai_formats::normalize_api_format_alias(api_format); let normalized = crate::ai_serving::normalize_api_format_alias(api_format);
let mut keys = aether_ai_formats::api_format_storage_aliases(&normalized); let mut keys = crate::ai_serving::api_format_storage_aliases(&normalized);
if !keys.iter().any(|value| value == &normalized) { if !keys.iter().any(|value| value == &normalized) {
keys.push(normalized); keys.push(normalized);
} }

7
apps/aether-gateway/src/ai_serving/pure/mod.rs
View File

@@ -2,9 +2,10 @@ pub(crate) use aether_ai_formats::api::{
aggregate_claude_stream_sync_response, aggregate_gemini_stream_sync_response, aggregate_claude_stream_sync_response, aggregate_gemini_stream_sync_response,
aggregate_openai_chat_stream_sync_response, aggregate_openai_responses_stream_sync_response, aggregate_openai_chat_stream_sync_response, aggregate_openai_responses_stream_sync_response,
aggregate_standard_chat_stream_sync_response, aggregate_standard_cli_stream_sync_response, aggregate_standard_chat_stream_sync_response, aggregate_standard_cli_stream_sync_response,
api_format_alias_matches, apply_codex_openai_responses_special_body_edits, api_format_alias_matches, api_format_storage_aliases,
apply_codex_openai_responses_special_headers, apply_model_directive_mapping_patch, apply_codex_openai_responses_special_body_edits, apply_codex_openai_responses_special_headers,
apply_model_directive_overrides_from_model, apply_model_directive_overrides_from_request, apply_model_directive_mapping_patch, apply_model_directive_overrides_from_model,
apply_model_directive_overrides_from_request,
apply_openai_responses_compact_special_body_edits, build_chatgpt_web_image_request_body, apply_openai_responses_compact_special_body_edits, build_chatgpt_web_image_request_body,
build_core_error_body_for_client_format, build_cross_format_openai_chat_request_body, build_core_error_body_for_client_format, build_cross_format_openai_chat_request_body,
build_cross_format_openai_chat_request_body_with_model_directives, build_cross_format_openai_chat_request_body_with_model_directives,

2
apps/aether-gateway/src/handlers/admin/provider/pool_admin/read_routes/scores.rs
View File

@@ -50,7 +50,7 @@ pub(super) async fn build_admin_pool_scores_response(
}; };
let offset = page.saturating_sub(1).saturating_mul(page_size); let offset = page.saturating_sub(1).saturating_mul(page_size);
let api_format = query_param_value(query, "api_format") let api_format = query_param_value(query, "api_format")
.map(|value| aether_ai_formats::normalize_api_format_alias(value.as_str())); .map(|value| crate::ai_serving::normalize_api_format_alias(value.as_str()));
let model_id = query_param_value(query, "model_id"); let model_id = query_param_value(query, "model_id");
let hard_states = match parse_hard_state_filter(query) { let hard_states = match parse_hard_state_filter(query) {
Ok(value) => value, Ok(value) => value,

2
crates/aether-data/src/lifecycle/bootstrap/postgres.rs
View File

@@ -7,7 +7,7 @@ use tracing::info;
// Generated by build.rs from schema/bootstrap/postgres. // Generated by build.rs from schema/bootstrap/postgres.
pub(crate) static EMPTY_DATABASE_SNAPSHOT_SQL: &str = pub(crate) static EMPTY_DATABASE_SNAPSHOT_SQL: &str =
include_str!(concat!(env!("OUT_DIR"), "/empty_database_snapshot.sql")); include_str!(concat!(env!("OUT_DIR"), "/empty_database_snapshot.sql"));
pub(crate) const EMPTY_DATABASE_SNAPSHOT_CUTOFF_VERSION: i64 = 20260511120000; pub(crate) const EMPTY_DATABASE_SNAPSHOT_CUTOFF_VERSION: i64 = 20260511130000;
const PUBLIC_BASE_TABLE_COUNT_SQL: &str = r#" const PUBLIC_BASE_TABLE_COUNT_SQL: &str = r#"
SELECT COUNT(*)::BIGINT SELECT COUNT(*)::BIGINT

8
crates/aether-data/src/lifecycle/migrate/tests.rs
View File

@@ -300,6 +300,7 @@ fn empty_database_snapshot_covers_current_cutoff_versions() {
20260510120000, 20260510120000,
20260511000000, 20260511000000,
20260511120000, 20260511120000,
20260511130000,
] ]
); );
} }
@@ -564,7 +565,8 @@ fn mysql_and_sqlite_migrations_include_enabled_incrementals() {
20260509000000, 20260509000000,
20260509120000, 20260509120000,
20260510120000, 20260510120000,
20260511120000 20260511120000,
20260511130000,
] ]
); );
assert_eq!( assert_eq!(
@@ -576,7 +578,8 @@ fn mysql_and_sqlite_migrations_include_enabled_incrementals() {
20260509000000, 20260509000000,
20260509120000, 20260509120000,
20260510120000, 20260510120000,
20260511120000 20260511120000,
20260511130000,
] ]
); );
} }
@@ -1088,6 +1091,7 @@ fn pending_migrations_from_applied_skips_versions_already_applied() {
20260510120000, 20260510120000,
20260511000000, 20260511000000,
20260511120000, 20260511120000,
20260511130000,
] ]
); );
} }