diff --git a/src/mito2/src/engine.rs b/src/mito2/src/engine.rs index 2a4a04af58..e48eb45cf1 100644 --- a/src/mito2/src/engine.rs +++ b/src/mito2/src/engine.rs @@ -40,7 +40,6 @@ mod drop_test; mod edit_region_test; #[cfg(test)] mod filter_deleted_test; -pub mod region_hook; #[cfg(test)] mod flush_test; #[cfg(test)] @@ -57,6 +56,7 @@ mod parallel_test; mod projection_test; #[cfg(test)] mod prune_test; +pub mod region_hook; #[cfg(test)] mod row_selector_test; #[cfg(test)] diff --git a/src/mito2/src/region.rs b/src/mito2/src/region.rs index 93ad67bb58..5fb34b7335 100644 --- a/src/mito2/src/region.rs +++ b/src/mito2/src/region.rs @@ -1203,10 +1203,11 @@ impl ManifestContext { } if let Some(hook) = hook - && let Some(action_list) = action_list_for_hook { - hook.on_manifest_updated(manifest.metadata.region_id, &action_list, version) - .await; - } + && let Some(action_list) = action_list_for_hook + { + hook.on_manifest_updated(manifest.metadata.region_id, &action_list, version) + .await; + } Ok(version) } diff --git a/src/mito2/src/worker/handle_copy_region.rs b/src/mito2/src/worker/handle_copy_region.rs index b8f6acf09f..739bef7904 100644 --- a/src/mito2/src/worker/handle_copy_region.rs +++ b/src/mito2/src/worker/handle_copy_region.rs @@ -19,7 +19,9 @@ use store_api::storage::{FileId, RegionId}; use crate::error::{InvalidRequestSnafu, MissingManifestSnafu, Result}; use crate::manifest::action::{RegionEdit, RegionMetaAction, RegionMetaActionList}; -use crate::region::{FileDescriptor, MitoRegionRef, RegionFileCopier, RegionLeaderState, RegionMetadataLoader}; +use crate::region::{ + FileDescriptor, MitoRegionRef, RegionFileCopier, RegionLeaderState, RegionMetadataLoader, +}; use crate::request::{ BackgroundNotify, CopyRegionFromFinished, CopyRegionFromRequest, WorkerRequest, }; @@ -228,7 +230,10 @@ impl RegionWorkerLoop { committed_sequence: None, }; let action_list = RegionMetaActionList::with_action(RegionMetaAction::Edit(edit.clone())); - info!("Applying {:?} to region {target_region_id}, reason: CopyRegionFrom", edit); + info!( + "Applying {:?} to region {target_region_id}, reason: CopyRegionFrom", + edit + ); let version = region .manifest_ctx .update_manifest(RegionLeaderState::Writable, action_list, false)