File tree Expand file tree Collapse file tree
quickwit/quickwit-serve/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -680,13 +680,12 @@ pub async fn serve_quickwit(
680680
681681 // The control plane listens for local shards updates to learn about each shard's ingestion
682682 // throughput.
683- let local_shards_update_listener_handle_opt = if node_config
684- . is_service_enabled ( QuickwitService :: ControlPlane )
685- {
686- Some ( setup_local_shards_update_listener ( cluster. clone ( ) , event_broker. clone ( ) ) . await )
687- } else {
688- None
689- } ;
683+ let local_shards_update_listener_handle_opt =
684+ if node_config. is_service_enabled ( QuickwitService :: ControlPlane ) {
685+ Some ( setup_local_shards_update_listener ( cluster. clone ( ) , event_broker. clone ( ) ) . await )
686+ } else {
687+ None
688+ } ;
690689
691690 let report_splits_subscription_handle_opt =
692691 // DISCLAIMER: This is quirky here: We base our decision to forward the split report depending
You can’t perform that action at this time.
0 commit comments