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

improvement: use read_metadata when manually scheduling

Browse source
This commit is contained in:
Zach Daniel 2023-08-24 17:10:29 -04:00
parent b628984c44
commit 706fcdfb7c
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lib/ash_oban.ex
View file

@ -247,7 +247,16 @@ defmodule AshOban do
primary_key = Ash.Resource.Info.primary_key(resource)
%{primary_key: Map.take(record, primary_key)}
metadata =
case trigger do
%{read_metadata: read_metadata} when is_function(read_metadata) ->
read_metadata.(record)
_ ->
%{}
end
%{primary_key: Map.take(record, primary_key), metadata: metadata}
|> trigger.worker.new()
|> Oban.insert!()
end