mirror of
https://github.com/ash-project/ash.git
synced 2024-09-20 05:23:03 +12:00
chore: format
This commit is contained in:
parent
45b66f539b
commit
28136ec43f
3 changed files with 32 additions and 31 deletions
|
@ -339,7 +339,6 @@ defmodule Ash.Actions.Update.Bulk do
|
|||
authorize_atomic_changeset(query, atomic_changeset, opts),
|
||||
{query, atomic_changeset} <- add_changeset_filters(query, atomic_changeset),
|
||||
{:ok, data_layer_query} <- Ash.Query.data_layer_query(query) do
|
||||
|
||||
case Ash.DataLayer.update_query(
|
||||
data_layer_query,
|
||||
atomic_changeset,
|
||||
|
|
|
@ -2109,43 +2109,45 @@ defmodule Ash.Changeset do
|
|||
Enum.reduce(
|
||||
changeset.atomics,
|
||||
changeset,
|
||||
fn {_key,
|
||||
%Ash.Query.Function.Error{
|
||||
arguments: arguments
|
||||
} = error}, changeset ->
|
||||
Enum.reduce_while(arguments, {:ok, []}, fn argument, {:ok, args} ->
|
||||
case Ash.Expr.eval(argument,
|
||||
resource: changeset.resource,
|
||||
unknown_on_unknown_refs?: true
|
||||
) do
|
||||
{:ok, value} ->
|
||||
{:cont, {:ok, [value | args]}}
|
||||
|
||||
_ ->
|
||||
{:halt, :error}
|
||||
end
|
||||
end)
|
||||
|> case do
|
||||
{:ok, args} ->
|
||||
error = %{error | arguments: args}
|
||||
|
||||
case Ash.Expr.eval(error,
|
||||
fn
|
||||
{_key,
|
||||
%Ash.Query.Function.Error{
|
||||
arguments: arguments
|
||||
} = error},
|
||||
changeset ->
|
||||
Enum.reduce_while(arguments, {:ok, []}, fn argument, {:ok, args} ->
|
||||
case Ash.Expr.eval(argument,
|
||||
resource: changeset.resource,
|
||||
unknown_on_unknown_refs?: true
|
||||
) do
|
||||
{:error, error} ->
|
||||
Ash.Changeset.add_error(changeset, error)
|
||||
{:ok, value} ->
|
||||
{:cont, {:ok, [value | args]}}
|
||||
|
||||
_ ->
|
||||
changeset
|
||||
{:halt, :error}
|
||||
end
|
||||
end)
|
||||
|> case do
|
||||
{:ok, args} ->
|
||||
error = %{error | arguments: args}
|
||||
|
||||
_ ->
|
||||
changeset
|
||||
end
|
||||
case Ash.Expr.eval(error,
|
||||
resource: changeset.resource,
|
||||
unknown_on_unknown_refs?: true
|
||||
) do
|
||||
{:error, error} ->
|
||||
Ash.Changeset.add_error(changeset, error)
|
||||
|
||||
{_key, _value}, changeset ->
|
||||
changeset
|
||||
_ ->
|
||||
changeset
|
||||
end
|
||||
|
||||
_ ->
|
||||
changeset
|
||||
end
|
||||
|
||||
{_key, _value}, changeset ->
|
||||
changeset
|
||||
end
|
||||
)
|
||||
else
|
||||
|
|
|
@ -3509,7 +3509,7 @@ defmodule Ash.Filter do
|
|||
end
|
||||
|
||||
{:ok, right} ->
|
||||
{:ok, %{expr | left: left, right: right}}
|
||||
{:ok, %{expr | left: left, right: right}}
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Reference in a new issue