Chunk timeline deletes (#12900)

This commit is contained in:
Nicolas Mowen 2024-08-09 15:42:51 -06:00
parent 3428baa3fa
commit 347d54f388

View File

@ -194,8 +194,12 @@ class EventCleanup(threading.Thread):
events_with_expired_clips = self.expire(EventCleanupType.clips) events_with_expired_clips = self.expire(EventCleanupType.clips)
# delete timeline entries for events that have expired recordings # delete timeline entries for events that have expired recordings
# delete up to 100,000 at a time
max_deletes = 100000
deleted_events_list = list(events_with_expired_clips)
for i in range(0, len(deleted_events_list), max_deletes):
Timeline.delete().where( Timeline.delete().where(
Timeline.source_id << events_with_expired_clips Timeline.source_id << deleted_events_list[i : i + max_deletes]
).execute() ).execute()
self.expire(EventCleanupType.snapshots) self.expire(EventCleanupType.snapshots)