From b09ef4686ab3547e803a9b36e7e61229d6b9c3a6 Mon Sep 17 00:00:00 2001
From: Gabriel Kaszewski <gabrielkaszewski@gmail.com>
Date: Thu, 11 Jun 2026 14:03:05 +0200
Subject: [PATCH] fmt

---
 .../tmdb-enrichment/src/person_handler.rs        |  6 +-----
 crates/application/src/person/enrich.rs          | 16 ++++++++++------
 crates/worker/src/main.rs                        |  6 +++---
 3 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/crates/adapters/tmdb-enrichment/src/person_handler.rs b/crates/adapters/tmdb-enrichment/src/person_handler.rs
index 32abfda..45e2bb2 100644
--- a/crates/adapters/tmdb-enrichment/src/person_handler.rs
+++ b/crates/adapters/tmdb-enrichment/src/person_handler.rs
@@ -1,9 +1,5 @@
 use async_trait::async_trait;
-use domain::{
-    errors::DomainError,
-    events::DomainEvent,
-    ports::EventHandler,
-};
+use domain::{errors::DomainError, events::DomainEvent, ports::EventHandler};
 
 use application::context::AppContext;
 
diff --git a/crates/application/src/person/enrich.rs b/crates/application/src/person/enrich.rs
index cf38ea6..d3a8bd2 100644
--- a/crates/application/src/person/enrich.rs
+++ b/crates/application/src/person/enrich.rs
@@ -1,13 +1,14 @@
 use crate::context::AppContext;
 use chrono::Utc;
-use domain::{
-    errors::DomainError,
-    models::PersonId,
-};
+use domain::{errors::DomainError, models::PersonId};
 
 const STALENESS_DAYS: i64 = 90;
 
-pub async fn execute(ctx: &AppContext, person_id: PersonId, external_id: &str) -> Result<(), DomainError> {
+pub async fn execute(
+    ctx: &AppContext,
+    person_id: PersonId,
+    external_id: &str,
+) -> Result<(), DomainError> {
     if let Some(person) = ctx.repos.person_query.get_by_id(&person_id).await?
         && let Some(at) = person.enriched_at()
         && (Utc::now() - at).num_days() < STALENESS_DAYS
@@ -29,7 +30,10 @@ pub async fn execute(ctx: &AppContext, person_id: PersonId, external_id: &str) -
         Err(e) => return Err(e),
     };
 
-    ctx.repos.person_command.update_enrichment(&person_id, &data).await?;
+    ctx.repos
+        .person_command
+        .update_enrichment(&person_id, &data)
+        .await?;
     tracing::info!(person_id = %person_id.value(), "person enriched");
     Ok(())
 }
diff --git a/crates/worker/src/main.rs b/crates/worker/src/main.rs
index 30797de..a956152 100644
--- a/crates/worker/src/main.rs
+++ b/crates/worker/src/main.rs
@@ -148,9 +148,9 @@ async fn main() -> anyhow::Result<()> {
                 )) as Arc<dyn EventHandler>;
                 ctx.services.person_enrichment =
                     Some(Arc::clone(&client) as Arc<dyn PersonEnrichmentClient>);
-                let person_handler = Arc::new(tmdb_enrichment::PersonEnrichmentHandler::new(
-                    ctx.clone(),
-                )) as Arc<dyn EventHandler>;
+                let person_handler =
+                    Arc::new(tmdb_enrichment::PersonEnrichmentHandler::new(ctx.clone()))
+                        as Arc<dyn EventHandler>;
                 let job = Arc::new(application::jobs::EnrichmentStalenessJob::new(ctx.clone()))
                     as Arc<dyn PeriodicJob>;
                 (Some(handler), Some(person_handler), Some(job))