Quiqup - Opus Stage Options

quiqup.opus_stage_options.ex

defmodule Quiqup.DispatchOrderStagePipeline do
  use Opus.Pipeline
  import Quiqup.Notifier, only: [emit_event: 1]

  check :valid_input?, with: &match?(%{order: _}, &1)
  check :validate_order, error_message: :order_is_not_valid
  step :assign_next_stage_slug, raise: true, if: :should_assign?
  step :assign_courier, instrument?: false
  step :persist_stage, raise: [PersistanceError]
  step :push_notification, retry_times: 3, retry_backoff: fn -> lin_backoff(10, 2) |> cap(100) end
  tee :emit_event, with: &emit_event(&1)
end