fix: fmt

Signed-off-by: Zhenchi <[email protected]>

src/mito2/src/sst/index/applier.rs

@@ -186,7 +186,7 @@ mod tests {
     use futures::io::Cursor;
     use index::inverted_index::search::index_apply::MockIndexApplier;
     use object_store::services::Memory;
-    use puffin::file_format::writer::{Blob, AsyncWriter, PuffinFileWriter};
+    use puffin::file_format::writer::{AsyncWriter, Blob, PuffinFileWriter};
 
     use super::*;
     use crate::error::Error;

src/mito2/src/sst/index/creator.rs

@@ -26,7 +26,7 @@ use index::inverted_index::create::sort_create::SortIndexCreator;
 use index::inverted_index::create::InvertedIndexCreator;
 use index::inverted_index::format::writer::InvertedIndexBlobWriter;
 use object_store::ObjectStore;
-use puffin::file_format::writer::{Blob, AsyncWriter, PuffinFileWriter};
+use puffin::file_format::writer::{AsyncWriter, Blob, PuffinFileWriter};
 use snafu::{ensure, ResultExt};
 use store_api::metadata::RegionMetadataRef;
 use tokio::io::duplex;

src/puffin/src/file_format/reader/file.rs

@@ -103,9 +103,7 @@ impl<'a, R: io::Read + io::Seek + 'a> SyncReader<'a> for PuffinFileReader<R> {
 }
 
 #[async_trait]
-impl<'a, R: AsyncRead + AsyncSeek + Unpin + Send + 'a> AsyncReader<'a>
-    for PuffinFileReader<R>
-{
+impl<'a, R: AsyncRead + AsyncSeek + Unpin + Send + 'a> AsyncReader<'a> for PuffinFileReader<R> {
     type Reader = PartialReader<&'a mut R>;
 
     async fn metadata(&'a mut self) -> Result<FileMetadata> {

src/puffin/src/file_format/writer/file.rs

@@ -22,7 +22,7 @@ use snafu::ResultExt;
 use crate::blob_metadata::{BlobMetadata, BlobMetadataBuilder, CompressionCodec};
 use crate::error::{CloseSnafu, FlushSnafu, Result, WriteSnafu};
 use crate::file_format::writer::footer::FooterWriter;
-use crate::file_format::writer::{Blob, AsyncWriter, SyncWriter};
+use crate::file_format::writer::{AsyncWriter, Blob, SyncWriter};
 use crate::file_format::MAGIC;
 
 /// Puffin file writer, implements both [`PuffinSyncWriter`] and [`PuffinAsyncWriter`]

src/puffin/src/puffin_manager.rs

@@ -12,9 +12,9 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-pub mod stager;
 pub mod file_accessor;
 pub mod fs_puffin_manager;
+pub mod stager;
 
 #[cfg(test)]
 mod tests;

src/puffin/src/puffin_manager/fs_puffin_manager/writer.rs

@@ -28,7 +28,7 @@ use crate::error::{
     DuplicateBlobSnafu, MetadataSnafu, OpenSnafu, Result, SerializeJsonSnafu,
     UnsupportedCompressionSnafu, WalkDirSnafu,
 };
-use crate::file_format::writer::{Blob, AsyncWriter, PuffinFileWriter};
+use crate::file_format::writer::{AsyncWriter, Blob, PuffinFileWriter};
 use crate::puffin_manager::fs_puffin_manager::dir_meta::{DirFileMetadata, DirMetadata};
 use crate::puffin_manager::stager::StagerRef;
 use crate::puffin_manager::{BlobGuard, DirGuard, PuffinWriter, PutOptions};

src/puffin/src/tests.rs

@@ -21,7 +21,7 @@ use futures::AsyncReadExt;
 use tokio_util::compat::TokioAsyncReadCompatExt;
 
 use crate::file_format::reader::{AsyncReader, PuffinFileReader, SyncReader};
-use crate::file_format::writer::{Blob, AsyncWriter, PuffinFileWriter, SyncWriter};
+use crate::file_format::writer::{AsyncWriter, Blob, PuffinFileWriter, SyncWriter};
 
 #[test]
 fn test_read_empty_puffin_sync() {