fix filter_existing_aggregate

metabrainz · Jan 7, 2025 · aa10cd7 · aa10cd7
1 parent 6328c2b
commit aa10cd7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/listenbrainz_spark/stats/incremental/listener/artist.py b/listenbrainz_spark/stats/incremental/listener/artist.py
@@ -27,7 +27,7 @@ def get_partial_aggregate_schema(self):
     def filter_existing_aggregate(self, existing_aggregate, incremental_aggregate):
         query = f"""
             WITH incremental_artists AS (
-                SELECT DISTINCT explode_outer(artist_credit_mbids) AS artist_mbid FROM {incremental_aggregate}
+                SELECT DISTINCT artist_mbid FROM {incremental_aggregate}
             )
             SELECT *
               FROM {existing_aggregate} ea