lateral join bongo

AmpelAstro · Feb 12, 2024 · c4a4ac4 · c4a4ac4
1 parent fc4c128
commit c4a4ac4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/migrations/02_add_archive_count.py b/migrations/02_add_archive_count.py
@@ -48,7 +48,7 @@
 
             print(row, count)
 
-    blobs = Archive.select().where(Archive.c.count != None).subquery().lateral()
+    blobs = Archive.select().where(Archive.c.count != None).lateral()
     alerts = sa.select([Alert.c.avro_archive_id]).where(
         Alert.c.avro_archive_id == blobs.c.avro_archive_id
     )