diff --git a/api/.sqlx/query-d0a3202bcfadd162663281444b1650ae4aaa1f80a8410aea2b1553a15a61ce86.json b/api/.sqlx/query-4378b33f7152f689beec4d7fbe98dc74d361c80a333e342bd11056c4c09e0f71.json
similarity index 65%
rename from api/.sqlx/query-d0a3202bcfadd162663281444b1650ae4aaa1f80a8410aea2b1553a15a61ce86.json
rename to api/.sqlx/query-4378b33f7152f689beec4d7fbe98dc74d361c80a333e342bd11056c4c09e0f71.json
index 5982aa6..9cb264e 100644
--- a/api/.sqlx/query-d0a3202bcfadd162663281444b1650ae4aaa1f80a8410aea2b1553a15a61ce86.json
+++ b/api/.sqlx/query-4378b33f7152f689beec4d7fbe98dc74d361c80a333e342bd11056c4c09e0f71.json
@@ -1,6 +1,6 @@
 {
   "db_name": "PostgreSQL",
-  "query": "\n        SELECT \n            m.id,\n            m.created_at,\n            m.attempt_at,\n            m.attempts,\n            p.payload_json\n        FROM mq_msgs m \n        LEFT JOIN mq_payloads p ON m.id = p.id\n        WHERE p.payload_json::jsonb ->> 'job_id' = $1\n        ",
+  "query": "\n        SELECT\n            m.id,\n            m.created_at,\n            m.attempt_at,\n            m.attempts,\n            p.payload_json\n        FROM mq_msgs m\n        LEFT JOIN mq_payloads p ON m.id = p.id\n        WHERE p.payload_json::jsonb ->> 'job_id' = $1\n        ",
   "describe": {
     "columns": [
       {
@@ -42,5 +42,5 @@
       true
     ]
   },
-  "hash": "d0a3202bcfadd162663281444b1650ae4aaa1f80a8410aea2b1553a15a61ce86"
+  "hash": "4378b33f7152f689beec4d7fbe98dc74d361c80a333e342bd11056c4c09e0f71"
 }
diff --git a/api/.sqlx/query-1773b673407c9c36e9fc66af2cef4ea1b28adfc37bbb5f194056f5a26d077639.json b/api/.sqlx/query-476a222abf10eedfe5cebebf21900bc3bbee11e855aa37f6c1ccc7d9bce5f87a.json
similarity index 51%
rename from api/.sqlx/query-1773b673407c9c36e9fc66af2cef4ea1b28adfc37bbb5f194056f5a26d077639.json
rename to api/.sqlx/query-476a222abf10eedfe5cebebf21900bc3bbee11e855aa37f6c1ccc7d9bce5f87a.json
index c4a1b6a..b16b8c8 100644
--- a/api/.sqlx/query-1773b673407c9c36e9fc66af2cef4ea1b28adfc37bbb5f194056f5a26d077639.json
+++ b/api/.sqlx/query-476a222abf10eedfe5cebebf21900bc3bbee11e855aa37f6c1ccc7d9bce5f87a.json
@@ -1,6 +1,6 @@
 {
   "db_name": "PostgreSQL",
-  "query": "\n        INSERT INTO job_results (\n            job_id, user_did, slice_uri, status, success, total_records,\n            collections_synced, repos_processed, message, error_message\n        ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)\n        ON CONFLICT (job_id) \n        DO UPDATE SET\n            status = EXCLUDED.status,\n            success = EXCLUDED.success,\n            total_records = EXCLUDED.total_records,\n            collections_synced = EXCLUDED.collections_synced,\n            repos_processed = EXCLUDED.repos_processed,\n            message = EXCLUDED.message,\n            error_message = EXCLUDED.error_message,\n            completed_at = NOW()\n        ",
+  "query": "\n        INSERT INTO job_results (\n            job_id, user_did, slice_uri, status, success, total_records,\n            collections_synced, repos_processed, message, error_message\n        ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)\n        ON CONFLICT (job_id)\n        DO UPDATE SET\n            status = EXCLUDED.status,\n            success = EXCLUDED.success,\n            total_records = EXCLUDED.total_records,\n            collections_synced = EXCLUDED.collections_synced,\n            repos_processed = EXCLUDED.repos_processed,\n            message = EXCLUDED.message,\n            error_message = EXCLUDED.error_message,\n            completed_at = NOW()\n        ",
   "describe": {
     "columns": [],
     "parameters": {
@@ -19,5 +19,5 @@
     },
     "nullable": []
   },
-  "hash": "1773b673407c9c36e9fc66af2cef4ea1b28adfc37bbb5f194056f5a26d077639"
+  "hash": "476a222abf10eedfe5cebebf21900bc3bbee11e855aa37f6c1ccc7d9bce5f87a"
 }
diff --git a/api/.sqlx/query-7b381dbc7d880598924a958f19be7823977b2c9f6d67f06bc4f3d9ed7396d363.json b/api/.sqlx/query-7b381dbc7d880598924a958f19be7823977b2c9f6d67f06bc4f3d9ed7396d363.json
new file mode 100644
index 0000000..73b1d34
--- /dev/null
+++ b/api/.sqlx/query-7b381dbc7d880598924a958f19be7823977b2c9f6d67f06bc4f3d9ed7396d363.json
@@ -0,0 +1,23 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT m.id\n        FROM mq_msgs m\n        JOIN mq_payloads p ON m.id = p.id\n        WHERE m.channel_name = 'sync_queue'\n        AND m.id != '00000000-0000-0000-0000-000000000000'\n        AND p.payload_json->>'user_did' = $1\n        AND p.payload_json->>'slice_uri' = $2\n        AND m.attempt_at <= NOW()\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "id",
+        "type_info": "Uuid"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "7b381dbc7d880598924a958f19be7823977b2c9f6d67f06bc4f3d9ed7396d363"
+}
diff --git a/api/.sqlx/query-e1053720f38d7ac898d980901bd7d58a6e85277a7c7b2191cc6ab818dbfbe3b5.json b/api/.sqlx/query-925239ddd618ebf1ca11d31578599ae2cffbc0fbab9c37ab59ce92c7fe68f42c.json
similarity index 80%
rename from api/.sqlx/query-e1053720f38d7ac898d980901bd7d58a6e85277a7c7b2191cc6ab818dbfbe3b5.json
rename to api/.sqlx/query-925239ddd618ebf1ca11d31578599ae2cffbc0fbab9c37ab59ce92c7fe68f42c.json
index a1d05f1..96997c3 100644
--- a/api/.sqlx/query-e1053720f38d7ac898d980901bd7d58a6e85277a7c7b2191cc6ab818dbfbe3b5.json
+++ b/api/.sqlx/query-925239ddd618ebf1ca11d31578599ae2cffbc0fbab9c37ab59ce92c7fe68f42c.json
@@ -1,6 +1,6 @@
 {
   "db_name": "PostgreSQL",
-  "query": "\n        SELECT \n            job_id, user_did, slice_uri, status, success, total_records,\n            collections_synced, repos_processed, message, error_message,\n            created_at, completed_at\n        FROM job_results \n        WHERE job_id = $1\n        ",
+  "query": "\n        SELECT\n            job_id, user_did, slice_uri, status, success, total_records,\n            collections_synced, repos_processed, message, error_message,\n            created_at, completed_at\n        FROM job_results\n        WHERE job_id = $1\n        ",
   "describe": {
     "columns": [
       {
@@ -84,5 +84,5 @@
       false
     ]
   },
-  "hash": "e1053720f38d7ac898d980901bd7d58a6e85277a7c7b2191cc6ab818dbfbe3b5"
+  "hash": "925239ddd618ebf1ca11d31578599ae2cffbc0fbab9c37ab59ce92c7fe68f42c"
 }
diff --git a/api/.sqlx/query-0747fa767581fddc88ecbb65eb975030a8426e586499f4bf9fa31370cc8c184a.json b/api/.sqlx/query-ddfae3b8aa362b8d0b31d45ec45117e4095e22c803cdc2b705d37981eeea7d56.json
similarity index 71%
rename from api/.sqlx/query-0747fa767581fddc88ecbb65eb975030a8426e586499f4bf9fa31370cc8c184a.json
rename to api/.sqlx/query-ddfae3b8aa362b8d0b31d45ec45117e4095e22c803cdc2b705d37981eeea7d56.json
index aa208d4..2377717 100644
--- a/api/.sqlx/query-0747fa767581fddc88ecbb65eb975030a8426e586499f4bf9fa31370cc8c184a.json
+++ b/api/.sqlx/query-ddfae3b8aa362b8d0b31d45ec45117e4095e22c803cdc2b705d37981eeea7d56.json
@@ -1,6 +1,6 @@
 {
   "db_name": "PostgreSQL",
-  "query": "\n        SELECT m.id\n        FROM mq_msgs m\n        JOIN mq_payloads p ON m.id = p.id\n        LEFT JOIN job_results jr ON (p.payload_json->>'job_id')::uuid = jr.job_id\n        WHERE m.channel_name = 'sync_queue'\n        AND m.id != '00000000-0000-0000-0000-000000000000'\n        AND p.payload_json->>'user_did' = $1 \n        AND p.payload_json->>'slice_uri' = $2\n        AND m.created_at > NOW() - INTERVAL '10 minutes'\n        AND jr.job_id IS NULL\n        ",
+  "query": "\n        SELECT m.id\n        FROM mq_msgs m\n        JOIN mq_payloads p ON m.id = p.id\n        LEFT JOIN job_results jr ON (p.payload_json->>'job_id')::uuid = jr.job_id\n        WHERE m.channel_name = 'sync_queue'\n        AND m.id != '00000000-0000-0000-0000-000000000000'\n        AND p.payload_json->>'user_did' = $1\n        AND p.payload_json->>'slice_uri' = $2\n        AND m.created_at > NOW() - INTERVAL '10 minutes'\n        AND jr.job_id IS NULL\n        ",
   "describe": {
     "columns": [
       {
@@ -19,5 +19,5 @@
       false
     ]
   },
-  "hash": "0747fa767581fddc88ecbb65eb975030a8426e586499f4bf9fa31370cc8c184a"
+  "hash": "ddfae3b8aa362b8d0b31d45ec45117e4095e22c803cdc2b705d37981eeea7d56"
 }
diff --git a/api/.sqlx/query-e638f20526ad4a43b0a20f0006913f767e1eacce2b26c5b692ddcdf7f9d4b629.json b/api/.sqlx/query-e638f20526ad4a43b0a20f0006913f767e1eacce2b26c5b692ddcdf7f9d4b629.json
deleted file mode 100644
index 9f74f2d..0000000
--- a/api/.sqlx/query-e638f20526ad4a43b0a20f0006913f767e1eacce2b26c5b692ddcdf7f9d4b629.json
+++ /dev/null
@@ -1,23 +0,0 @@
-{
-  "db_name": "PostgreSQL",
-  "query": "\n        SELECT m.id \n        FROM mq_msgs m\n        JOIN mq_payloads p ON m.id = p.id\n        WHERE m.channel_name = 'sync_queue'\n        AND m.id != '00000000-0000-0000-0000-000000000000'\n        AND p.payload_json->>'user_did' = $1 \n        AND p.payload_json->>'slice_uri' = $2\n        AND m.attempt_at <= NOW()\n        ",
-  "describe": {
-    "columns": [
-      {
-        "ordinal": 0,
-        "name": "id",
-        "type_info": "Uuid"
-      }
-    ],
-    "parameters": {
-      "Left": [
-        "Text",
-        "Text"
-      ]
-    },
-    "nullable": [
-      false
-    ]
-  },
-  "hash": "e638f20526ad4a43b0a20f0006913f767e1eacce2b26c5b692ddcdf7f9d4b629"
-}