Kick off job after saving changes

controller.ex

defmodule UserController do
  def create(params) do
    changeset = params
                |> cast([:name, :email])
                |> validate_required([:email])
                |> validate_other_stuff()
    WithSideEffects.create(changeset)
  end
end

with_side_effects.ex

defmodule WithSideEffects do
  def create(changeset) do
    case Repo.insert(changeset) do
      {:ok, record} ->
        async_publish_job(record, :create)
        
      {:error, changeset} ->
        {:error, changeset}
    end
  end
end