From 981e659c8f3756b35bb04160ff6edc4cb0c843c9 Mon Sep 17 00:00:00 2001 From: Zach Daniel Date: Fri, 6 Oct 2023 20:44:01 -0400 Subject: [PATCH] fix: pass metadata argument on the udpate action --- lib/transformers/define_schedulers.ex | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/lib/transformers/define_schedulers.ex b/lib/transformers/define_schedulers.ex index 7f71cb0..879a809 100644 --- a/lib/transformers/define_schedulers.ex +++ b/lib/transformers/define_schedulers.ex @@ -489,7 +489,7 @@ defmodule AshOban.Transformers.DefineSchedulers do else quote location: :keep do @impl unquote(worker) - def unquote(function_name)(%Oban.Job{args: %{"primary_key" => primary_key}} = job) do + def unquote(function_name)(%Oban.Job{args: %{"primary_key" => primary_key} = args} = job) do AshOban.debug( "Trigger #{unquote(inspect(resource))}.#{unquote(trigger.name)} triggered for primary key #{inspect(primary_key)}", unquote(trigger.debug?) @@ -514,7 +514,9 @@ defmodule AshOban.Transformers.DefineSchedulers do |> Ash.Changeset.new() |> prepare(primary_key) |> Ash.Changeset.set_context(%{private: %{ash_oban?: true}}) - |> Ash.Changeset.for_action(unquote(trigger.action), %{}) + |> Ash.Changeset.for_action(unquote(trigger.action), %{ + metadata: args["metadata"] || %{} + }) |> AshOban.update_or_destroy(unquote(api)) |> case do :ok ->