fix: Fix migration 012 for empty table and update postgres.rs for UUID arrays

- Remove WHERE clause from migration UPDATE statements to handle empty tables
- Fix jsonb_array_elements_text usage in migration for proper UUID extraction
- Update postgres.rs dependency resolution to use UUID array operations

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: CodingAnarchy

src/migrations/012_optimize_dependencies.postgres.sql

@@ -19,12 +19,11 @@ SET depends_on_array = CASE
     WHEN jsonb_typeof(depends_on) = 'array' THEN 
         ARRAY(
             SELECT elem::UUID 
-            FROM jsonb_array_elements_text(depends_on) AS elem(value)
-            WHERE elem.value ~ '^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$'
+            FROM jsonb_array_elements_text(depends_on) AS elem
+            WHERE elem::text ~ '^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$'
         )
     ELSE '{}'::UUID[]
-END
-WHERE depends_on_array = '{}';
+END;
 
 -- Handle dependents column with UUID validation
 UPDATE hammerwork_jobs 
@@ -33,12 +32,11 @@ SET dependents_array = CASE
     WHEN jsonb_typeof(dependents) = 'array' THEN 
         ARRAY(
             SELECT elem::UUID 
-            FROM jsonb_array_elements_text(dependents) AS elem(value)
-            WHERE elem.value ~ '^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$'
+            FROM jsonb_array_elements_text(dependents) AS elem
+            WHERE elem::text ~ '^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$'
         )
     ELSE '{}'::UUID[]
-END
-WHERE dependents_array = '{}';
+END;
 
 -- Step 3: Verify data migration integrity
 DO $$

src/queue/postgres.rs

@@ -1779,19 +1779,19 @@ impl DatabaseQueue for crate::queue::JobQueue<Postgres> {
             r#"
             SELECT id, depends_on
             FROM hammerwork_jobs
-            WHERE depends_on @> $1::jsonb
+            WHERE $1 = ANY(depends_on)
             AND dependency_status = 'waiting'
             "#,
         )
-        .bind(serde_json::json!([completed_job_id]))
+        .bind(completed_job_id)
         .fetch_all(&self.pool)
         .await?;
 
         let mut resolved_jobs = Vec::new();
 
         for job_row in dependent_jobs {
             let job_id: uuid::Uuid = job_row.get("id");
-            let depends_on: Vec<uuid::Uuid> = serde_json::from_value(job_row.get("depends_on"))?;
+            let depends_on: Vec<uuid::Uuid> = job_row.get("depends_on");
 
             // Check if all dependencies are now satisfied
             let satisfied_count = sqlx::query_scalar::<_, i64>(
@@ -1860,12 +1860,12 @@ impl DatabaseQueue for crate::queue::JobQueue<Postgres> {
                 r#"
                 SELECT id
                 FROM hammerwork_jobs
-                WHERE depends_on @> $1::jsonb
+                WHERE $1 = ANY(depends_on)
                 AND dependency_status IN ('waiting', 'satisfied')
                 AND status = 'Pending'
                 "#,
             )
-            .bind(serde_json::json!([current_job_id]))
+            .bind(current_job_id)
             .fetch_all(&self.pool)
             .await?;