ash-project/ash
1
0
Fork 0
mirror of https://github.com/ash-project/ash.git synced 2024-09-19 21:13:10 +12:00
Code Issues Projects Releases Packages Wiki Activity

fix: ensure proper return types for :stream strategy bulk update/destroys

Browse source
This commit is contained in:
Zach Daniel 2024-09-06 15:46:02 -04:00
parent 9e21d6209b
commit 44c0d09e30
2 changed files with 15 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lib/ash/actions/destroy/bulk.ex
View file

@ -474,7 +474,12 @@ defmodule Ash.Actions.Destroy.Bulk do
handle_bulk_result(bulk_result, resource, action, opts) handle_bulk_result(bulk_result, resource, action, opts)
{:error, error} -> {:error, error} ->
[{:error, error}] handle_bulk_result(
%Ash.BulkResult{errors: [error], status: :error},
resource,
action,
opts
)
end end
after after
if notify? do if notify? do
@ -1384,7 +1389,9 @@ defmodule Ash.Actions.Destroy.Bulk do
result result
{:error, error} -> {:error, error} ->
[{:error, error}] store_error(ref, error, opts)
[]
end end
after after
if notify? do if notify? do
@ -1968,6 +1975,7 @@ defmodule Ash.Actions.Destroy.Bulk do
{:error, error} -> {:error, error} ->
store_error(ref, error, opts) store_error(ref, error, opts)
[] []
end end
end) end)

6
lib/ash/actions/update/bulk.ex
View file

@ -436,7 +436,11 @@ defmodule Ash.Actions.Update.Bulk do
handle_bulk_result(bulk_result, metadata_key, opts) handle_bulk_result(bulk_result, metadata_key, opts)
{:error, error} -> {:error, error} ->
{:error, error} handle_bulk_result(
%Ash.BulkResult{errors: [error], status: :error},
metadata_key,
opts
)
end end
after after
if notify? do if notify? do