diff --git a/packages/db/remove_original_content.py b/packages/db/remove_original_content.py index 60516804d..fa050c3b0 100755 --- a/packages/db/remove_original_content.py +++ b/packages/db/remove_original_content.py @@ -27,8 +27,9 @@ def batch_update_library_items(conn): LIMIT {batch_size} ) """) - rows_updated = cursor.rowcount conn.commit() + + rows_updated = cursor.rowcount if rows_updated == 0: break