diff --git a/unifi_protect_backup/missing_event_checker.py b/unifi_protect_backup/missing_event_checker.py
index 59b6de5..10027d9 100644
--- a/unifi_protect_backup/missing_event_checker.py
+++ b/unifi_protect_backup/missing_event_checker.py
@@ -93,7 +93,7 @@ class MissingEventChecker:
 
         return downloading_event_ids | uploading_event_ids
 
-    async def _get_new_missing_events(self, existing_ids) -> AsyncIterator[Event]:
+    async def _get_new_missing_events(self) -> AsyncIterator[Event]:
         now = datetime.now(timezone.utc)
         retention_start = now - self.retention
 
@@ -111,6 +111,10 @@ class MissingEventChecker:
         new_last_check_time = end_time
         chunk_size = 500
 
+        existing_ids = (
+            await self._get_ongoing_event_ids() | await self._get_backedup_event_ids() | set(self.missing_events.keys())
+        )
+
         # Check UniFi Protect for new missing events
         while True:
             # Get list of events that need to be backed up from UniFi protect
@@ -219,9 +223,7 @@ class MissingEventChecker:
                     await self._add_to_download_queue(event)
 
                 logger.extra_debug("Checking for new missing events")  # type: ignore[attr-defined]
-                async for event in self._get_new_missing_events(
-                    db_event_ids | in_progress_ids | set(self.missing_events.keys())
-                ):
+                async for event in self._get_new_missing_events():
                     logger.debug(f"Found new missing event: '{event.id}")
                     self.missing_events[event.id] = MissingEvent(event, 0)
                     await self._add_to_download_queue(event)