Skip to main content

lib/continuum/runtime/activity_worker/supervisor.ex

defmodule Continuum.Runtime.ActivityWorker.Supervisor do
  @moduledoc """
  Dynamic supervisor for activity worker processes.
  """

  use DynamicSupervisor

  @doc false
  def start_link(opts \\ []) do
    instance = Continuum.Runtime.Instance.lookup(Keyword.get(opts, :instance, Continuum))
    DynamicSupervisor.start_link(__MODULE__, opts, name: instance.activity_supervisor)
  end

  @impl true
  def init(_opts) do
    DynamicSupervisor.init(strategy: :one_for_one)
  end
end