Add playlist id offset to legacy indexing

AudiusProject · Jul 29, 2022 · 18b715e · 18b715e
1 parent 9af986c
commit 18b715e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/discovery-provider/src/tasks/playlists.py b/discovery-provider/src/tasks/playlists.py
@@ -16,6 +16,7 @@
 )
 
 logger = logging.getLogger(__name__)
+MIN_PLAYLIST_ID = 400000
 
 
 def playlist_state_update(
@@ -63,7 +64,7 @@ def playlist_state_update(
                         )
 
                     # parse playlist event to add metadata to record
-                    playlist_record = parse_playlist_event(
+                    playlist_record: Playlist = parse_playlist_event(
                         self,
                         update_task,
                         entry,
@@ -72,6 +73,9 @@ def playlist_state_update(
                         block_timestamp,
                         session,
                     )
+                    if playlist_record.playlist_id > MIN_PLAYLIST_ID:
+                        logger.info(f"index.py | playlists.py | Playlist {playlist_record.playlist_id} is above the playlist ID offset {MIN_PLAYLIST_ID}. Skipping transaction.")
+                        continue
 
                     # process playlist record
                     if playlist_record is not None: