rafaels88

Quiqup.DispatchOrderStagePipeline.call(%{order: order}, only: [:valid_input?])

Quiqup.DispatchOrderStagePipeline.call(%{order: order}, except: [:push_notification, :emit_event])

rafaels88

defmodule Quiqup.DispatchOrderStagePipeline do
  step :persist

  instrument :stage_completed, %{stage: %{name: :persist}}, fn %{time: time} ->
    # send to the monitoring tool of your choice
  end
end

rafaels88

defmodule PipelineInstrumentation do
  def instrument(:pipeline_started, %{pipeline: Quiqup.DispatchOrderStagePipeline}, %{input: input}) do
    # publish the metrics to a specific backend
  end

  def instrument(:stage_completed, %{stage: %{pipeline: Quiqup.DispatchOrderStagePipeline}}, %{time: time}) do
    # publish the metrics to a specific backend
  end
end

rafaels88

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

rafaels88

defmodule Quiqup.DispatchOrderStagePipeline do
  use Opus.Pipeline, raise: true
  
  # ...
end

rafaels88

defmodule Quiqup.DispatchOrderStagePipeline do
  use Opus.Pipeline, instrument?: false 
  # ...
end

rafaels88

defmodule Quiqup.DispatchOrderStagePipeline do
  use Opus.Pipeline
  # ...
  skip if: :job_is_finished?
  # ...
  @spec job_is_finished?(map()) :: bool()
end