diff --git a/src/data_source/extension.rs b/src/data_source/extension.rs
index 6831930c..7477f0ed 100644
--- a/src/data_source/extension.rs
+++ b/src/data_source/extension.rs
@@ -119,11 +119,13 @@ where
     D: VersionedDataSource + Send,
     U: Send + Sync,
 {
-    type Transaction<'a> = D::Transaction<'a>
+    type Transaction<'a>
+        = D::Transaction<'a>
     where
         Self: 'a;
 
-    type ReadOnly<'a> = D::ReadOnly<'a>
+    type ReadOnly<'a>
+        = D::ReadOnly<'a>
     where
         Self: 'a;
 
@@ -144,22 +146,28 @@ where
     Types: NodeType,
     Payload<Types>: QueryablePayload<Types>,
 {
-    type LeafRange<R> = D::LeafRange<R>
+    type LeafRange<R>
+        = D::LeafRange<R>
     where
         R: RangeBounds<usize> + Send;
-    type BlockRange<R> = D::BlockRange<R>
+    type BlockRange<R>
+        = D::BlockRange<R>
     where
         R: RangeBounds<usize> + Send;
-    type PayloadRange<R> = D::PayloadRange<R>
+    type PayloadRange<R>
+        = D::PayloadRange<R>
     where
         R: RangeBounds<usize> + Send;
-    type PayloadMetadataRange<R> = D::PayloadMetadataRange<R>
+    type PayloadMetadataRange<R>
+        = D::PayloadMetadataRange<R>
     where
         R: RangeBounds<usize> + Send;
-    type VidCommonRange<R> = D::VidCommonRange<R>
+    type VidCommonRange<R>
+        = D::VidCommonRange<R>
     where
         R: RangeBounds<usize> + Send;
-    type VidCommonMetadataRange<R> = D::VidCommonMetadataRange<R>
+    type VidCommonMetadataRange<R>
+        = D::VidCommonMetadataRange<R>
     where
         R: RangeBounds<usize> + Send;
 
diff --git a/src/data_source/fetching.rs b/src/data_source/fetching.rs
index 61deed94..715f96bd 100644
--- a/src/data_source/fetching.rs
+++ b/src/data_source/fetching.rs
@@ -559,22 +559,28 @@ where
     for<'a> S::ReadOnly<'a>: AvailabilityStorage<Types> + NodeStorage<Types> + PrunedHeightStorage,
     P: AvailabilityProvider<Types>,
 {
-    type LeafRange<R> = BoxStream<'static, Fetch<LeafQueryData<Types>>>
+    type LeafRange<R>
+        = BoxStream<'static, Fetch<LeafQueryData<Types>>>
     where
         R: RangeBounds<usize> + Send;
-    type BlockRange<R> = BoxStream<'static, Fetch<BlockQueryData<Types>>>
+    type BlockRange<R>
+        = BoxStream<'static, Fetch<BlockQueryData<Types>>>
     where
         R: RangeBounds<usize> + Send;
-    type PayloadRange<R> = BoxStream<'static, Fetch<PayloadQueryData<Types>>>
+    type PayloadRange<R>
+        = BoxStream<'static, Fetch<PayloadQueryData<Types>>>
     where
         R: RangeBounds<usize> + Send;
-    type PayloadMetadataRange<R> = BoxStream<'static, Fetch<PayloadMetadata<Types>>>
+    type PayloadMetadataRange<R>
+        = BoxStream<'static, Fetch<PayloadMetadata<Types>>>
     where
         R: RangeBounds<usize> + Send;
-    type VidCommonRange<R> = BoxStream<'static, Fetch<VidCommonQueryData<Types>>>
+    type VidCommonRange<R>
+        = BoxStream<'static, Fetch<VidCommonQueryData<Types>>>
     where
         R: RangeBounds<usize> + Send;
-    type VidCommonMetadataRange<R> = BoxStream<'static, Fetch<VidCommonMetadata<Types>>>
+    type VidCommonMetadataRange<R>
+        = BoxStream<'static, Fetch<VidCommonMetadata<Types>>>
     where
         R: RangeBounds<usize> + Send;
 
@@ -714,10 +720,12 @@ where
     S: VersionedDataSource + Send + Sync,
     P: Send + Sync,
 {
-    type Transaction<'a> = S::Transaction<'a>
+    type Transaction<'a>
+        = S::Transaction<'a>
     where
         Self: 'a;
-    type ReadOnly<'a> = S::ReadOnly<'a>
+    type ReadOnly<'a>
+        = S::ReadOnly<'a>
     where
         Self: 'a;
 
@@ -760,10 +768,12 @@ where
     S: VersionedDataSource + Send + Sync,
     P: Send + Sync,
 {
-    type Transaction<'a> = S::Transaction<'a>
+    type Transaction<'a>
+        = S::Transaction<'a>
     where
         Self: 'a;
-    type ReadOnly<'a> = S::ReadOnly<'a>
+    type ReadOnly<'a>
+        = S::ReadOnly<'a>
     where
         Self: 'a;
 
diff --git a/src/data_source/storage/fail_storage.rs b/src/data_source/storage/fail_storage.rs
index c52010c7..3a9cae47 100644
--- a/src/data_source/storage/fail_storage.rs
+++ b/src/data_source/storage/fail_storage.rs
@@ -205,10 +205,12 @@ impl<S> VersionedDataSource for FailStorage<S>
 where
     S: VersionedDataSource,
 {
-    type Transaction<'a> = Transaction<S::Transaction<'a>>
+    type Transaction<'a>
+        = Transaction<S::Transaction<'a>>
     where
         Self: 'a;
-    type ReadOnly<'a> = Transaction<S::ReadOnly<'a>>
+    type ReadOnly<'a>
+        = Transaction<S::ReadOnly<'a>>
     where
         Self: 'a;
 
diff --git a/src/data_source/storage/fs.rs b/src/data_source/storage/fs.rs
index bfb1122d..bf66b84a 100644
--- a/src/data_source/storage/fs.rs
+++ b/src/data_source/storage/fs.rs
@@ -357,10 +357,12 @@ impl<Types: NodeType> VersionedDataSource for FileSystemStorage<Types>
 where
     Payload<Types>: QueryablePayload<Types>,
 {
-    type Transaction<'a> = Transaction<RwLockWriteGuard<'a, FileSystemStorageInner<Types>>>
+    type Transaction<'a>
+        = Transaction<RwLockWriteGuard<'a, FileSystemStorageInner<Types>>>
     where
         Self: 'a;
-    type ReadOnly<'a> = Transaction<RwLockReadGuard<'a, FileSystemStorageInner<Types>>>
+    type ReadOnly<'a>
+        = Transaction<RwLockReadGuard<'a, FileSystemStorageInner<Types>>>
     where
         Self: 'a;
 
diff --git a/src/data_source/storage/no_storage.rs b/src/data_source/storage/no_storage.rs
index 3f67055d..841f4366 100644
--- a/src/data_source/storage/no_storage.rs
+++ b/src/data_source/storage/no_storage.rs
@@ -56,10 +56,12 @@ pub struct Transaction<'a> {
 }
 
 impl VersionedDataSource for NoStorage {
-    type Transaction<'a> = Transaction<'a>
+    type Transaction<'a>
+        = Transaction<'a>
     where
         Self: 'a;
-    type ReadOnly<'a> = Transaction<'a>
+    type ReadOnly<'a>
+        = Transaction<'a>
     where
         Self: 'a;
 
@@ -457,10 +459,12 @@ pub mod testing {
     // Now a lot of boilerplate to implement all teh traits for [`DataSource`], by dispatching each
     // method to either variant.
     impl VersionedDataSource for DataSource {
-        type Transaction<'a> = Transaction<'a, <SqlStorage as VersionedDataSource>::Transaction<'a>>
+        type Transaction<'a>
+            = Transaction<'a, <SqlStorage as VersionedDataSource>::Transaction<'a>>
         where
             Self: 'a;
-        type ReadOnly<'a> = Transaction<'a, <SqlStorage as VersionedDataSource>::ReadOnly<'a>>
+        type ReadOnly<'a>
+            = Transaction<'a, <SqlStorage as VersionedDataSource>::ReadOnly<'a>>
         where
             Self: 'a;
 
@@ -549,22 +553,28 @@ pub mod testing {
 
     #[async_trait]
     impl AvailabilityDataSource<MockTypes> for DataSource {
-        type LeafRange<R> = BoxStream<'static, Fetch<LeafQueryData<MockTypes>>>
+        type LeafRange<R>
+            = BoxStream<'static, Fetch<LeafQueryData<MockTypes>>>
         where
             R: RangeBounds<usize> + Send;
-        type BlockRange<R> = BoxStream<'static, Fetch<BlockQueryData<MockTypes>>>
+        type BlockRange<R>
+            = BoxStream<'static, Fetch<BlockQueryData<MockTypes>>>
         where
             R: RangeBounds<usize> + Send;
-        type PayloadRange<R> = BoxStream<'static, Fetch<PayloadQueryData<MockTypes>>>
+        type PayloadRange<R>
+            = BoxStream<'static, Fetch<PayloadQueryData<MockTypes>>>
         where
             R: RangeBounds<usize> + Send;
-        type PayloadMetadataRange<R> = BoxStream<'static, Fetch<PayloadMetadata<MockTypes>>>
+        type PayloadMetadataRange<R>
+            = BoxStream<'static, Fetch<PayloadMetadata<MockTypes>>>
         where
             R: RangeBounds<usize> + Send;
-        type VidCommonRange<R> = BoxStream<'static, Fetch<VidCommonQueryData<MockTypes>>>
+        type VidCommonRange<R>
+            = BoxStream<'static, Fetch<VidCommonQueryData<MockTypes>>>
         where
             R: RangeBounds<usize> + Send;
-        type VidCommonMetadataRange<R> = BoxStream<'static, Fetch<VidCommonMetadata<MockTypes>>>
+        type VidCommonMetadataRange<R>
+            = BoxStream<'static, Fetch<VidCommonMetadata<MockTypes>>>
         where
             R: RangeBounds<usize> + Send;
 
diff --git a/src/data_source/storage/sql.rs b/src/data_source/storage/sql.rs
index 07941fc0..06c8902f 100644
--- a/src/data_source/storage/sql.rs
+++ b/src/data_source/storage/sql.rs
@@ -653,10 +653,12 @@ impl PruneStorage for SqlStorage {
 }
 
 impl VersionedDataSource for SqlStorage {
-    type Transaction<'a> = Transaction<Write>
+    type Transaction<'a>
+        = Transaction<Write>
     where
         Self: 'a;
-    type ReadOnly<'a> = Transaction<Read>
+    type ReadOnly<'a>
+        = Transaction<Read>
     where
         Self: 'a;
 
diff --git a/src/lib.rs b/src/lib.rs
index 7bf465fc..e77ab5a9 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -627,40 +627,28 @@ mod test {
 
     #[async_trait]
     impl AvailabilityDataSource<MockTypes> for CompositeState {
-        type LeafRange<R> =
-            <MockDataSource as AvailabilityDataSource<
-                MockTypes,
-            >>::LeafRange<R>
+        type LeafRange<R>
+            = <MockDataSource as AvailabilityDataSource<MockTypes>>::LeafRange<R>
         where
             R: RangeBounds<usize> + Send;
-        type BlockRange<R> =
-            <MockDataSource as AvailabilityDataSource<
-                MockTypes,
-            >>::BlockRange<R>
+        type BlockRange<R>
+            = <MockDataSource as AvailabilityDataSource<MockTypes>>::BlockRange<R>
         where
             R: RangeBounds<usize> + Send;
-        type PayloadRange<R> =
-            <MockDataSource as AvailabilityDataSource<
-                MockTypes,
-            >>::PayloadRange<R>
+        type PayloadRange<R>
+            = <MockDataSource as AvailabilityDataSource<MockTypes>>::PayloadRange<R>
         where
             R: RangeBounds<usize> + Send;
-        type PayloadMetadataRange<R> =
-            <MockDataSource as AvailabilityDataSource<
-                MockTypes,
-            >>::PayloadMetadataRange<R>
+        type PayloadMetadataRange<R>
+            = <MockDataSource as AvailabilityDataSource<MockTypes>>::PayloadMetadataRange<R>
         where
             R: RangeBounds<usize> + Send;
-        type VidCommonRange<R> =
-            <MockDataSource as AvailabilityDataSource<
-                MockTypes,
-            >>::VidCommonRange<R>
+        type VidCommonRange<R>
+            = <MockDataSource as AvailabilityDataSource<MockTypes>>::VidCommonRange<R>
         where
             R: RangeBounds<usize> + Send;
-        type VidCommonMetadataRange<R> =
-            <MockDataSource as AvailabilityDataSource<
-                MockTypes,
-            >>::VidCommonMetadataRange<R>
+        type VidCommonMetadataRange<R>
+            = <MockDataSource as AvailabilityDataSource<MockTypes>>::VidCommonMetadataRange<R>
         where
             R: RangeBounds<usize> + Send;