View Source AshOban.Trigger (ash_oban v0.2.6)
A configured trigger.
Summary
Types
@type t() :: %AshOban.Trigger{ __identifier__: atom(), action: atom(), action_input: map(), debug?: boolean(), lock_for_update?: boolean(), log_errors?: boolean(), log_final_error?: boolean(), max_attempts: pos_integer(), max_scheduler_attempts: pos_integer(), name: atom(), on_error: atom(), queue: atom(), read_action: atom(), read_metadata: (Ash.Resource.record() -> map()), record_limit: pos_integer(), scheduler: module() | nil, scheduler_cron: String.t(), scheduler_priority: non_neg_integer(), scheduler_queue: atom(), state: :active | :paused | :deleted, stream_batch_size: pos_integer(), where: Ash.Expr.t(), worker: module(), worker_priority: non_neg_integer(), worker_read_action: term() }