Quiqup - Opus Step

quiqup.opus_step.ex

defmodule Quiqup.DispatchOrderStagePipeline do
  use Opus.Pipeline

  step :assign_courier
  step :next_stage

  def assign_courier(%{order: order} = pipeline) do
    put_in(pipeline, [:courier], order.courier)
  end

  def next_stage(%{order: order, courier: courier}) do
    # ...
  end
end

Quiqup.DispatchOrderStagePipeline.call(%{order: order})