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

fix: don't schedule triggers with no scheduler

Browse source
This commit is contained in:
Zach Daniel 2023-09-15 15:48:33 -04:00
parent 06c340569f
commit c74eb9f8f5
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/test.ex
View file

@ -8,6 +8,7 @@ defmodule AshOban.Test do
|> Ash.Api.Info.resources()
|> Enum.reduce(%{}, fn resource, acc ->
resource
|> IO.inspect()
|> schedule_and_run_triggers()
|> Map.merge(acc, fn _key, left, right ->
left + right
@ -16,7 +17,11 @@ defmodule AshOban.Test do
Spark.Dsl.is?(resource_or_api_or_otp_app, Ash.Resource) ->
triggers =
AshOban.Info.oban_triggers(resource_or_api_or_otp_app)
resource_or_api_or_otp_app
|> AshOban.Info.oban_triggers()
|> Enum.filter(fn trigger ->
trigger.scheduler
end)
Enum.each(triggers, fn trigger ->
AshOban.schedule(resource_or_api_or_otp_app, trigger)
@ -41,6 +46,8 @@ defmodule AshOban.Test do
|> Application.get_env(:ash_apis, [])
|> List.wrap()
|> Enum.reduce(%{}, fn api, acc ->
IO.inspect(api)
api
|> schedule_and_run_triggers()
|> Map.merge(acc, fn _key, left, right ->