diff --git a/core/crates/cloud-services/src/sync/ingest.rs b/core/crates/cloud-services/src/sync/ingest.rs
index cabede505b62..f943fc9aa785 100644
--- a/core/crates/cloud-services/src/sync/ingest.rs
+++ b/core/crates/cloud-services/src/sync/ingest.rs
@@ -82,7 +82,7 @@ enum IngestStatus {
 }
 
 impl Ingester {
-	pub const  fn new(
+	pub const fn new(
 		sync: SyncManager,
 		ingest_notify: Arc<Notify>,
 		active: Arc<AtomicBool>,
diff --git a/core/crates/heavy-lifting/src/job_system/job.rs b/core/crates/heavy-lifting/src/job_system/job.rs
index 4afa393d1da2..ec664c3272f7 100644
--- a/core/crates/heavy-lifting/src/job_system/job.rs
+++ b/core/crates/heavy-lifting/src/job_system/job.rs
@@ -1167,7 +1167,8 @@ impl JobTaskDispatcher {
 						matches!(
 							*state,
 							JobRunningState::Running
-								| JobRunningState::Canceled | JobRunningState::Shutdown
+								| JobRunningState::Canceled
+								| JobRunningState::Shutdown
 						)
 					})
 					.await
diff --git a/core/crates/heavy-lifting/src/job_system/report.rs b/core/crates/heavy-lifting/src/job_system/report.rs
index d0e5f01084e3..3d536e7dd565 100644
--- a/core/crates/heavy-lifting/src/job_system/report.rs
+++ b/core/crates/heavy-lifting/src/job_system/report.rs
@@ -344,8 +344,10 @@ impl Status {
 		matches!(
 			self,
 			Self::Completed
-				| Self::Canceled | Self::Paused
-				| Self::Failed | Self::CompletedWithErrors
+				| Self::Canceled
+				| Self::Paused
+				| Self::Failed
+				| Self::CompletedWithErrors
 		)
 	}
 }
diff --git a/core/crates/heavy-lifting/src/job_system/store.rs b/core/crates/heavy-lifting/src/job_system/store.rs
index 74058708a179..82847dadc076 100644
--- a/core/crates/heavy-lifting/src/job_system/store.rs
+++ b/core/crates/heavy-lifting/src/job_system/store.rs
@@ -83,7 +83,9 @@ pub async fn load_jobs<OuterCtx: OuterContext, JobCtx: JobContext<OuterCtx>>(
 					     root_job: StoredJob { id, .. },
 					     next_jobs,
 					     ..
-					 }| { iter::once(*id).chain(next_jobs.iter().map(|StoredJob { id, .. }| *id)) },
+					 }| {
+						iter::once(*id).chain(next_jobs.iter().map(|StoredJob { id, .. }| *id))
+					},
 				)
 				.map(|job_id| uuid_to_bytes(&job_id))
 				.collect::<Vec<_>>(),
diff --git a/core/crates/heavy-lifting/src/media_processor/helpers/ffmpeg_media_data.rs b/core/crates/heavy-lifting/src/media_processor/helpers/ffmpeg_media_data.rs
index ebcc65a63846..18888178a735 100644
--- a/core/crates/heavy-lifting/src/media_processor/helpers/ffmpeg_media_data.rs
+++ b/core/crates/heavy-lifting/src/media_processor/helpers/ffmpeg_media_data.rs
@@ -61,12 +61,15 @@ pub const fn can_extract_for_audio(audio_extension: AudioExtension) -> bool {
 	matches!(
 		audio_extension,
 		Mp3 | Mp2
-			| M4a | Wav | Aiff
-			| Aif | Flac | Ogg
-			| Oga | Opus | Wma
-			| Amr | Aac | Wv
-			| Voc | Tta | Loas
-			| Caf | Aptx | Adts
+			| M4a | Wav
+			| Aiff | Aif
+			| Flac | Ogg
+			| Oga | Opus
+			| Wma | Amr
+			| Aac | Wv
+			| Voc | Tta
+			| Loas | Caf
+			| Aptx | Adts
 			| Ast | Mid
 	)
 }
@@ -81,15 +84,18 @@ pub const fn can_extract_for_video(video_extension: VideoExtension) -> bool {
 	matches!(
 		video_extension,
 		Avi | Avifs
-			| Qt | Mov | Swf
-			| Mjpeg | Mpeg
-			| Mxf | M2v | Mpg
-			| Mpe | M2ts | Flv
-			| Wm | _3gp | M4v
-			| Wmv | Asf | Mp4
-			| Webm | Mkv | Vob
-			| Ogv | Wtv | Hevc
-			| F4v // | Ts | Mts  TODO: Uncomment when we start using magic instead of extension
+			| Qt | Mov
+			| Swf | Mjpeg
+			| Mpeg | Mxf
+			| M2v | Mpg
+			| Mpe | M2ts
+			| Flv | Wm
+			| _3gp | M4v
+			| Wmv | Asf
+			| Mp4 | Webm
+			| Mkv | Vob
+			| Ogv | Wtv
+			| Hevc | F4v // | Ts | Mts  TODO: Uncomment when we start using magic instead of extension
 	)
 }
 
diff --git a/core/crates/sync/src/manager.rs b/core/crates/sync/src/manager.rs
index 218c30e9f7ce..8d3ed15eeaf9 100644
--- a/core/crates/sync/src/manager.rs
+++ b/core/crates/sync/src/manager.rs
@@ -284,7 +284,7 @@ impl Manager {
 		device_pub_id: &'a DevicePubId,
 		chunk_size: u32,
 		initial_timestamp: NTP64,
-	) -> impl Stream<Item = Result<Vec<CRDTOperation>, Error>> + Send + '_ {
+	) -> impl Stream<Item = Result<Vec<CRDTOperation>, Error>> + Send + 'a {
 		stream! {
 			let mut current_initial_timestamp = initial_timestamp;
 
diff --git a/core/src/location/mod.rs b/core/src/location/mod.rs
index 164b7d53216e..3ce4da296828 100644
--- a/core/src/location/mod.rs
+++ b/core/src/location/mod.rs
@@ -752,7 +752,8 @@ async fn create_location(
 		.location()
 		.count(vec![location::path::equals(Some(path.clone()))])
 		.exec()
-		.await? > 0
+		.await?
+		> 0
 	{
 		return Err(LocationError::LocationAlreadyExists(location_path.into()));
 	}
diff --git a/core/src/old_job/report.rs b/core/src/old_job/report.rs
index 60761ab170a6..ed40df23d40e 100644
--- a/core/src/old_job/report.rs
+++ b/core/src/old_job/report.rs
@@ -418,8 +418,10 @@ impl JobStatus {
 		matches!(
 			self,
 			Self::Completed
-				| Self::Canceled | Self::Paused
-				| Self::Failed | Self::CompletedWithErrors
+				| Self::Canceled
+				| Self::Paused
+				| Self::Failed
+				| Self::CompletedWithErrors
 		)
 	}
 }
diff --git a/crates/actors/src/lib.rs b/crates/actors/src/lib.rs
index 0eaa0724c946..0604bed523cc 100644
--- a/crates/actors/src/lib.rs
+++ b/crates/actors/src/lib.rs
@@ -169,7 +169,7 @@ impl<Id: ActorId> ActorsCollection<Id> {
 
 	#[instrument(skip(self))]
 	pub async fn start(&self, identifier: Id) {
-		let mut actors_map  = self.actors_map.write().await;
+		let mut actors_map = self.actors_map.write().await;
 		if let Some(actor) = actors_map.get_mut(&identifier) {
 			if actor.is_running.load(Ordering::Acquire) {
 				warn!("Actor already running!");