From 3a5525edf68f2b4062e9bb680a36b6d435b84b62 Mon Sep 17 00:00:00 2001
From: iLLiCiTiT <jakub.trllo@gmail.com>
Date: Wed, 23 Oct 2019 18:45:41 +0200
Subject: [PATCH] processed events older than 3 days are removed from mongo db

---
 pype/ftrack/ftrack_server/session_processor.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/pype/ftrack/ftrack_server/session_processor.py b/pype/ftrack/ftrack_server/session_processor.py
index 2dfa94dc94..686e89dc79 100644
--- a/pype/ftrack/ftrack_server/session_processor.py
+++ b/pype/ftrack/ftrack_server/session_processor.py
@@ -1,6 +1,7 @@
 import logging
 import os
 import atexit
+import datetime
 import tempfile
 import threading
 import time
@@ -83,6 +84,12 @@ class ProcessEventHub(ftrack_api.event.hub.EventHub):
 
     def load_events(self):
         """Load not processed events sorted by stored date"""
+        ago_date = datetime.datetime.now() - datetime.timedelta(days=3)
+        result = self.dbcon.delete_many({
+            "pype_data.stored": {"$lte": ago_date},
+            "pype_data.is_processed": True
+        })
+
         not_processed_events = self.dbcon.find(
             {"pype_data.is_processed": False}
         ).sort(