File tree 2 files changed +4
-4
lines changed 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(
63
63
)
64
64
. route (
65
65
"/flows/:flowInstName/rowStatus" ,
66
- routing:: get ( service:: flows:: get_row_index_status ) ,
66
+ routing:: get ( service:: flows:: get_row_indexing_status ) ,
67
67
)
68
68
. route (
69
69
"/flows/:flowInstName/update" ,
Original file line number Diff line number Diff line change @@ -209,17 +209,17 @@ pub async fn update(
209
209
Ok ( Json ( live_updater. index_update_info ( ) ) )
210
210
}
211
211
212
- pub async fn get_row_index_status (
212
+ pub async fn get_row_indexing_status (
213
213
Path ( flow_name) : Path < String > ,
214
214
Query ( query) : Query < SourceRowKeyParams > ,
215
215
State ( lib_context) : State < Arc < LibContext > > ,
216
216
) -> Result < Json < indexing_status:: SourceRowIndexingStatus > , ApiError > {
217
217
let flow_ctx = lib_context. get_flow_context ( & flow_name) ?;
218
218
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 (
220
220
& source_row_key_ctx. as_context ( ) ,
221
221
& lib_context. builtin_db_pool ,
222
222
)
223
223
. await ?;
224
- Ok ( Json ( index_status ) )
224
+ Ok ( Json ( indexing_status ) )
225
225
}
You can’t perform that action at this time.
0 commit comments