Packages

gpt_agent

7.0.0
10.0.0 9.2.3 9.2.2 9.2.1 9.2.0 9.1.0 9.0.1 9.0.0 8.1.1 8.1.0 8.0.0 7.0.1 7.0.0 6.2.0 6.1.0 6.0.1 6.0.0 5.1.1 5.1.0 5.0.0 4.0.0 3.2.2 3.2.1 3.1.1 3.1.0 3.0.0 2.1.3 2.1.2 2.1.1 2.1.0 2.0.0 1.0.0

A client for the OpenAI Assistants API

HexDocs

Current section

Files

Jump to
Readme
32 Versions
8 Dependencies
Dependants
Files
Activity
gpt_agent lib gpt_agent supervisor.ex
Raw

lib/gpt_agent/supervisor.ex 

defmodule GptAgent.Supervisor do

  @moduledoc """

  Manages the GptAgent processes, ensuring that there is only one process per thread-id.

  """



  use DynamicSupervisor



  require Logger



  def start_link(init_arg) do

    log_level =

      Application.get_env(:gpt_agent, :log_level) || Application.get_env(:logger, :level) ||

        :warning



    Logger.put_module_level(__MODULE__, log_level)

    Logger.put_module_level(GptAgent, log_level)

    {:ok, pid} = DynamicSupervisor.start_link(__MODULE__, init_arg, name: __MODULE__)

    Logger.info("Started GptAgent.Supervisor with pid #{inspect(pid)}")



    result =

      DynamicSupervisor.start_child(pid, {Registry, [keys: :unique, name: GptAgent.Registry]})



    Logger.info("Started GptAgent.Registry: #{inspect(result)}")

    result = DynamicSupervisor.start_child(pid, {Phoenix.PubSub, [name: GptAgent.PubSub]})

    Logger.info("Started GptAgent.PubSub: #{inspect(result)}")

    {:ok, pid}

  end



  @impl DynamicSupervisor

  def init(_init_arg) do

    DynamicSupervisor.init(strategy: :one_for_one)

  end

end