diff --git a/backend/spi/spi-stats/src/serv/pg/stats_pg_conf_dim_group_serv.rs b/backend/spi/spi-stats/src/serv/pg/stats_pg_conf_dim_group_serv.rs index af1bb5c54..5f7649146 100644 --- a/backend/spi/spi-stats/src/serv/pg/stats_pg_conf_dim_group_serv.rs +++ b/backend/spi/spi-stats/src/serv/pg/stats_pg_conf_dim_group_serv.rs @@ -111,7 +111,7 @@ async fn do_paginate( ) -> TardisResult> { let table_name = package_table_name("stats_conf_dim_group", ctx); let sql_where = vec!["1 = 1".to_string()]; - let mut sql_order= vec![]; + let mut sql_order = vec![]; let params: Vec = vec![Value::from(page_size), Value::from((page_number - 1) * page_size)]; if let Some(desc_by_create) = desc_by_create { diff --git a/frontend/sdks/invoke/src/clients/spi_log_client.rs b/frontend/sdks/invoke/src/clients/spi_log_client.rs index 2136cd482..81fefb3fc 100644 --- a/frontend/sdks/invoke/src/clients/spi_log_client.rs +++ b/frontend/sdks/invoke/src/clients/spi_log_client.rs @@ -1,4 +1,3 @@ -use asteroid_mq::prelude::{EventAttribute, Subject}; use serde::{Deserialize, Serialize}; use tardis::{ @@ -29,6 +28,12 @@ pub mod event { impl EventAttribute for super::LogItemAddV2Req { const SUBJECT: Subject = Subject::const_new("log/add"); } + impl EventAttribute for super::StatsItemAddReq { + const SUBJECT: Subject = Subject::const_new("stats/add"); + } + impl EventAttribute for super::StatsItemDeleteReq { + const SUBJECT: Subject = Subject::const_new("stats/delete"); + } } #[derive(Debug, Default, Clone)] pub struct SpiLogClient; @@ -118,10 +123,6 @@ pub struct StatsItemAddReq { pub own_paths: Option, } -impl EventAttribute for StatsItemAddReq { - const SUBJECT: Subject = Subject::const_new("stats/add"); -} - #[derive(poem_openapi::Object, Serialize, Deserialize, Clone, Debug)] pub struct StatsItemDeleteReq { #[oai(validator(min_length = "2"))] @@ -132,10 +133,6 @@ pub struct StatsItemDeleteReq { pub key: Option, } -impl EventAttribute for StatsItemDeleteReq { - const SUBJECT: Subject = Subject::const_new("stats/delete"); -} - impl SpiLogClient { #[deprecated] pub async fn add_dynamic_log(