Marked as queued a long time ago

greg-finley · Sep 3, 2024 · 0442ba4 · 0442ba4
1 parent cc83221
commit 0442ba4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/queue_files/main.py b/queue_files/main.py
@@ -74,13 +74,14 @@ def run(event, context):
             except Exception as err:
                 print(f"Failed to delete {clean_name}: {err}")
 
-    # also reenque all failed files
+    # also reenque all failed files or queued a long time ago
     with conn.cursor() as cursor:
         cursor.execute(
             """
             SELECT id, desktop_path 
             FROM dropbox 
             WHERE status = 'failed'
+            OR (status = 'pending' AND created_at < CURRENT_TIMESTAMP - INTERVAL '1 hour')
             FOR UPDATE SKIP LOCKED
             """
         )