cargo fmt

Author: jtwaleson

src/bgworker/mod.rs

@@ -625,7 +625,11 @@ pub trait BackgroundWorker<A: Send + Sync + serde::Serialize + 'static>: Send +
         Self::perform_later_with_priority(ctx, args, None).await
     }
 
-    async fn perform_later_with_priority(ctx: &AppContext, args: A, priority: Option<i32>) -> crate::Result<()>
+    async fn perform_later_with_priority(
+        ctx: &AppContext,
+        args: A,
+        priority: Option<i32>,
+    ) -> crate::Result<()>
     where
         Self: Sized,
     {
@@ -634,8 +638,14 @@ pub trait BackgroundWorker<A: Send + Sync + serde::Serialize + 'static>: Send +
                 if let Some(p) = &ctx.queue_provider {
                     let tags = Self::tags();
                     let tags_option = if tags.is_empty() { None } else { Some(tags) };
-                    p.enqueue(Self::class_name(), Self::queue(), args, tags_option, priority)
-                        .await?;
+                    p.enqueue(
+                        Self::class_name(),
+                        Self::queue(),
+                        args,
+                        tags_option,
+                        priority,
+                    )
+                    .await?;
                 } else {
                     tracing::error!(
                         "perform_later: background queue is selected, but queue was not populated \

src/bgworker/pg.rs

@@ -232,13 +232,13 @@ async fn connect(cfg: &PostgresQueueConfig) -> Result<PgPool> {
 /// This function will return an error if it fails
 pub async fn initialize_database(pool: &PgPool) -> Result<()> {
     debug!("Initializing job database tables");
-    
+
     // First, check if the table exists
     let table_exists: bool = sqlx::query_scalar(
         "SELECT EXISTS (
             SELECT FROM information_schema.tables 
             WHERE table_name = 'pg_loco_queue'
-        )"
+        )",
     )
     .fetch_one(pool)
     .await?;
@@ -271,7 +271,7 @@ pub async fn initialize_database(pool: &PgPool) -> Result<()> {
                 SELECT FROM information_schema.columns 
                 WHERE table_name = 'pg_loco_queue' 
                 AND column_name = 'priority'
-            )"
+            )",
         )
         .fetch_one(pool)
         .await?;
@@ -283,7 +283,7 @@ pub async fn initialize_database(pool: &PgPool) -> Result<()> {
                 .await?;
         }
     }
-    
+
     Ok(())
 }