ash-project/ash
1
0
Fork 0
mirror of https://github.com/ash-project/ash.git synced 2024-09-20 05:23:03 +12:00
Code Issues Projects Releases Packages Wiki Activity

improvement: add config :ash, disable_async?: true

Browse source
This commit is contained in:
Zach Daniel 2021-09-08 22:55:22 -04:00
parent c7cfa878e7
commit 64ec412e5d
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/ash/engine/engine.ex
View file

@ -491,10 +491,11 @@ defmodule Ash.Engine do
end
defp split_local_async_requests(requests) do
if Enum.any?(requests, fn request ->
Ash.DataLayer.data_layer_can?(request.resource, :transact) &&
Ash.DataLayer.in_transaction?(request.resource)
end) do
if Application.get_env(:ash, :disable_async?) ||
Enum.any?(requests, fn request ->
Ash.DataLayer.data_layer_can?(request.resource, :transact) &&
Ash.DataLayer.in_transaction?(request.resource)
end) do
{requests, []}
else
{local, async} = Enum.split_with(requests, &must_be_local?/1)