diff --git a/frigate/events/cleanup.py b/frigate/events/cleanup.py
index 713e33630..d4efb26e8 100644
--- a/frigate/events/cleanup.py
+++ b/frigate/events/cleanup.py
@@ -121,8 +121,8 @@ class EventCleanup(threading.Thread):
 
             events_to_update = []
 
-            for batch in query.iterator():
-                events_to_update.extend([event.id for event in batch])
+            for event in query.iterator():
+                events_to_update.append(event.id)
                 if len(events_to_update) >= CHUNK_SIZE:
                     logger.debug(
                         f"Updating {update_params} for {len(events_to_update)} events"
@@ -257,7 +257,7 @@ class EventCleanup(threading.Thread):
         events_to_update = []
 
         for event in query.iterator():
-            events_to_update.append(event)
+            events_to_update.append(event.id)
 
             if len(events_to_update) >= CHUNK_SIZE:
                 logger.debug(