mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-07-04 13:00:38 +00:00
chore: fmt
This commit is contained in:
@@ -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)]
|
||||
|
||||
@@ -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)
|
||||
}
|
||||
|
||||
@@ -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<S> RegionWorkerLoop<S> {
|
||||
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)
|
||||
|
||||
Reference in New Issue
Block a user