feat: add manual? trigger flag to stop scheduler creation

lib/ash_oban.ex

@@ -19,7 +19,8 @@ defmodule AshOban do
             state: :active | :paused | :deleted,
             worker: module,
             __identifier__: atom,
-            on_error: atom
+            on_error: atom,
+            manual?: boolean
           }
 
     defstruct [
@@ -38,6 +39,7 @@ defmodule AshOban do
       :scheduler,
       :worker,
       :on_error,
+      :manual?,
       :__identifier__
     ]
 
@@ -140,6 +142,12 @@ defmodule AshOban do
         type: :atom,
         doc:
           "An update action to call after the last attempt has failed. See the getting started guide for more."
+      ],
+      manual?: [
+        type: :boolean,
+        default: :false,
+        doc:
+          "Whether to only run the trigger manually (with `run_trigger`) instead of on a cron schedule."
       ]
     ]
   }
@@ -252,7 +260,11 @@ defmodule AshOban do
     end)
     |> Enum.reduce(base, fn {resource, trigger}, config ->
       require_queues!(config, resource, trigger)
-      add_job(config, cron_plugin, resource, trigger)
+      if trigger.manual? == false do
+        add_job(config, cron_plugin, resource, trigger)
+      else
+        config
+      end
     end)
   end
 

lib/transformers/define_schedulers.ex

@@ -27,8 +27,14 @@ defmodule AshOban.Transformers.DefineSchedulers do
       |> Transformer.async_compile(fn ->
         define_worker(module, worker_module_name, trigger, dsl)
       end)
-      |> Transformer.async_compile(fn ->
-        define_scheduler(module, scheduler_module_name, worker_module_name, trigger, dsl)
+      |> then(fn dsl ->
+        if trigger.manual? == false do
+          Transformer.async_compile(dsl, fn ->
+            define_scheduler(module, scheduler_module_name, worker_module_name, trigger, dsl)
+          end)
+        else
+          dsl
+        end
       end)
     end)
     |> then(&{:ok, &1})

lib/transformers/set_defaults.ex

@@ -54,7 +54,8 @@ defmodule AshOban.Transformers.SetDefaults do
          | read_action: read_action.name,
            queue: queue,
            scheduler_queue: trigger.scheduler_queue || queue,
-           action: trigger.action || trigger.name
+           action: trigger.action || trigger.name,
+           manual?: trigger.manual? || false
        })
      end)}
   end