improvement: use read_metadata when manually scheduling

ash-project · Aug 24, 2023 · 706fcdf · 706fcdf
1 parent b628984
commit 706fcdf
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/lib/ash_oban.ex b/lib/ash_oban.ex
@@ -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