diff --git a/packages/db/migrations/0181.do.batch_delete_trash_items.sql b/packages/db/migrations/0181.do.batch_delete_trash_items.sql
index 38a619469..38518b6b6 100755
--- a/packages/db/migrations/0181.do.batch_delete_trash_items.sql
+++ b/packages/db/migrations/0181.do.batch_delete_trash_items.sql
@@ -5,7 +5,7 @@
 BEGIN;
 
 CREATE OR REPLACE PROCEDURE omnivore.batch_delete_trash_items()
-RETURNS VOID AS $$
+LANGUAGE plpgsql AS $$
 DECLARE
     user_record RECORD;
     user_cursor CURSOR FOR
@@ -17,20 +17,21 @@ DECLARE
         status = 'ACTIVE';
 BEGIN
     FOR user_record IN user_cursor LOOP
-        BEGIN;
+        BEGIN
         
-        -- For Row Level Security
-        PERFORM omnivore.set_claims(user_record.id, 'omnivore_user');
+            -- For Row Level Security
+            PERFORM omnivore.set_claims(user_record.id, 'omnivore_user');
 
-        DELETE FROM omnivore.library_item
-        WHERE
-            user_id = user_record.id
-            AND state = 'DELETED'
-            AND deleted_at < NOW() - INTERVAL '14 days';
+            DELETE FROM omnivore.library_item
+            WHERE
+                user_id = user_record.id
+                AND state = 'DELETED'
+                AND deleted_at < NOW() - INTERVAL '14 days';
 
-        COMMIT;
+            COMMIT;
+        END;
     END LOOP;
-END;
-$$ LANGUAGE plpgsql;
+END
+$$;
 
 COMMIT;