From b85e60126084e0026da8efc9c70eaab3fe5e1c41 Mon Sep 17 00:00:00 2001 From: LJ Date: Sun, 11 May 2025 12:55:55 -0700 Subject: [PATCH] chore: fix method names --- src/server.rs | 2 +- src/service/flows.rs | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/server.rs b/src/server.rs index f48df77e..14221976 100644 --- a/src/server.rs +++ b/src/server.rs @@ -63,7 +63,7 @@ pub async fn init_server( ) .route( "/flows/:flowInstName/rowStatus", - routing::get(service::flows::get_row_index_status), + routing::get(service::flows::get_row_indexing_status), ) .route( "/flows/:flowInstName/update", diff --git a/src/service/flows.rs b/src/service/flows.rs index 07c43dfe..f0d243ff 100644 --- a/src/service/flows.rs +++ b/src/service/flows.rs @@ -209,17 +209,17 @@ pub async fn update( Ok(Json(live_updater.index_update_info())) } -pub async fn get_row_index_status( +pub async fn get_row_indexing_status( Path(flow_name): Path, Query(query): Query, State(lib_context): State>, ) -> Result, ApiError> { let flow_ctx = lib_context.get_flow_context(&flow_name)?; let source_row_key_ctx = SourceRowKeyContextHolder::create(&flow_ctx, query).await?; - let index_status = indexing_status::get_source_row_indexing_status( + let indexing_status = indexing_status::get_source_row_indexing_status( &source_row_key_ctx.as_context(), &lib_context.builtin_db_pool, ) .await?; - Ok(Json(index_status)) + Ok(Json(indexing_status)) }