defmodule HiiveRisk.DecisionWorker do
  use Oban.Worker,
    queue: :risk_decision,
    max_attempts: 5,
    unique: [
      period: :infinity,
      keys: [:case_id],
      states: [:available, :scheduled, :executing, :retryable, :completed]
    ]

  @impl true
  def perform(job), do: HiiveRisk.Pipeline.perform(:decision, job)
end

defmodule HiiveRisk.SFTWorker do
  use Oban.Worker,
    queue: :risk_sft,
    max_attempts: 5,
    unique: [
      period: :infinity,
      keys: [:case_id],
      states: [:available, :scheduled, :executing, :retryable, :completed]
    ]

  @impl true
  def perform(job), do: HiiveRisk.Pipeline.perform(:sft, job)
end