do not bookkeep incremental aggregate if inc dumps do not exist

metabrainz · Mar 4, 2025 · 1581e68 · 1581e68
1 parent 4a4ab5c
commit 1581e68
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/listenbrainz_spark/stats/incremental/incremental_stats_engine.py b/listenbrainz_spark/stats/incremental/incremental_stats_engine.py
@@ -230,4 +230,5 @@ def run(self) -> Iterator[Dict]:
         self.prepare_final_aggregate()
         results = self.generate_stats()
         yield from self.create_messages(results, self.only_inc, self.message_creator)
-        self.bookkeep_incremental_aggregate()
+        if incremental_listens_exist():
+            self.bookkeep_incremental_aggregate()