Fix active product query

upmaru · Feb 26, 2024 · cc14cd0 · cc14cd0
1 parent 06fe57d
commit cc14cd0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/polar/streams/product.ex b/lib/polar/streams/product.ex
@@ -58,7 +58,8 @@ defmodule Polar.Streams.Product do
     from(
       p in queryable,
       join: v in assoc(p, :active_versions),
-      where: not is_nil(v.product_id)
+      where: not is_nil(v.product_id),
+      group_by: [:id]
     )
   end