mirror of
https://github.com/ash-project/ash.git
synced 2024-09-20 13:33:20 +12:00
chore: fix stream option taking (again)
This commit is contained in:
parent
248f99ebcf
commit
f4339be426
2 changed files with 2 additions and 3 deletions
|
@ -39,8 +39,7 @@ defmodule Ash.Actions.Update.Bulk do
|
|||
case fully_atomic_changeset do
|
||||
{:not_atomic, _} ->
|
||||
read_opts =
|
||||
opts
|
||||
|> Keyword.take(Ash.Api.stream_opts())
|
||||
Keyword.take(opts, Ash.Api.stream_opt_keys())
|
||||
|
||||
read_opts =
|
||||
if stream_batch_size = opts[:stream_batch_size] do
|
||||
|
|
|
@ -199,7 +199,7 @@ defmodule Ash.Api do
|
|||
)
|
||||
|
||||
@doc false
|
||||
def stream_opts, do: @stream_opts
|
||||
def stream_opt_keys, do: Keyword.keys(@stream_opts)
|
||||
|
||||
@doc """
|
||||
Streams the results of a query.
|
||||
|
|
Loading…
Reference in a new issue