Delete corrupted release items

10 years ago · c7491dfcbf
1 changed files with 2 additions and 0 deletions
--- a/couchpotato/core/plugins/release/main.py
+++ b/couchpotato/core/plugins/release/main.py
@ -555,6 +555,8 @@ class Release(Plugin):
                releases.append(doc)
            except RecordDeleted:
                pass
+            except (ValueError, EOFError):
+                fireEvent('database.delete_corrupted', r.get('_id'), traceback_error = traceback.format_exc(0))

        releases = sorted(releases, key = lambda k: k.get('info', {}).get('score', 0), reverse = True)