fix: don't double add distinct clauses

ash-project · Oct 28, 2024 · e94aeab · e94aeab
1 parent 474d804
commit e94aeab
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/data_layer.ex b/lib/data_layer.ex
@@ -1097,6 +1097,8 @@ defmodule AshPostgres.DataLayer do
             where: ^source_filter
           )
 
+        data_layer_query = Ecto.Query.exclude(data_layer_query, :distinct)
+
         if query.__ash_bindings__[:__order__?] do
           {:ok,
            from(source in data_layer_query,
@@ -1186,6 +1188,8 @@ defmodule AshPostgres.DataLayer do
                   )
                 )
 
+              data_layer_query = Ecto.Query.exclude(data_layer_query, :distinct)
+
               {:ok,
                from(source in data_layer_query,
                  where: field(source, ^source_attribute) in ^source_values,
@@ -1224,6 +1228,8 @@ defmodule AshPostgres.DataLayer do
                   )
                 )
 
+              data_layer_query = Ecto.Query.exclude(data_layer_query, :distinct)
+
               {:ok,
                from(source in data_layer_query,
                  where: field(source, ^source_attribute) in ^source_values,