fix: use unpaginated_read when simulating streaming for low limit q…

…ueries
ash-project · Jul 14, 2024 · 47a7967 · 47a7967
1 parent 56b98e8
commit 47a7967
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/ash/actions/destroy/bulk.ex b/lib/ash/actions/destroy/bulk.ex
@@ -161,7 +161,7 @@ defmodule Ash.Actions.Destroy.Bulk do
             if query.limit && query.limit < (opts[:batch_size] || 100) do
               read_opts = Keyword.take(read_opts, Keyword.keys(Ash.read_opts()))
 
-              case Ash.read(query, read_opts) do
+              case Ash.Actions.Read.unpaginated_read(query, read_opts) do
                 {:ok, results} ->
                   run(
                     domain,

diff --git a/lib/ash/actions/update/bulk.ex b/lib/ash/actions/update/bulk.ex
@@ -120,7 +120,7 @@ defmodule Ash.Actions.Update.Bulk do
             if query.limit && query.limit < (opts[:batch_size] || 100) do
               read_opts = Keyword.take(read_opts, Keyword.keys(Ash.read_opts()))
 
-              case Ash.read(query, read_opts) do
+              case Ash.Actions.Read.unpaginated_read(query, read_opts) do
                 {:ok, results} ->
                   run(
                     domain,