File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -63,7 +63,7 @@ pub async fn init_server(
6363 )
6464 . route (
6565 "/flows/:flowInstName/rowStatus" ,
66- routing:: get ( service:: flows:: get_row_index_status ) ,
66+ routing:: get ( service:: flows:: get_row_indexing_status ) ,
6767 )
6868 . route (
6969 "/flows/:flowInstName/update" ,
Original file line number Diff line number Diff line change @@ -209,17 +209,17 @@ pub async fn update(
209209 Ok ( Json ( live_updater. index_update_info ( ) ) )
210210}
211211
212- pub async fn get_row_index_status (
212+ pub async fn get_row_indexing_status (
213213 Path ( flow_name) : Path < String > ,
214214 Query ( query) : Query < SourceRowKeyParams > ,
215215 State ( lib_context) : State < Arc < LibContext > > ,
216216) -> Result < Json < indexing_status:: SourceRowIndexingStatus > , ApiError > {
217217 let flow_ctx = lib_context. get_flow_context ( & flow_name) ?;
218218 let source_row_key_ctx = SourceRowKeyContextHolder :: create ( & flow_ctx, query) . await ?;
219- let index_status = indexing_status:: get_source_row_indexing_status (
219+ let indexing_status = indexing_status:: get_source_row_indexing_status (
220220 & source_row_key_ctx. as_context ( ) ,
221221 & lib_context. builtin_db_pool ,
222222 )
223223 . await ?;
224- Ok ( Json ( index_status ) )
224+ Ok ( Json ( indexing_status ) )
225225}
You can’t perform that action at this time.
0 commit comments