Packages

beam_weaver

0.1.8
0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Elixir-native LangChain, LangGraph, and DeepAgents for traceable LLM apps: OTP workflows, tools, memory, human-in-the-loop, streaming, custom clients/adapters, minimal deps, and WeaveScope tracing.

Current section

Files

Jump to
Readme
15 Versions
7 Dependencies
Dependants
Files
Activity
beam_weaver lib beam_weaver tracing runner.ex
Raw

lib/beam_weaver/tracing/runner.ex 

defmodule BeamWeaver.Tracing.Runner do

  @moduledoc false



  alias BeamWeaver.Tracing



  @spec run(String.t() | atom(), keyword(), keyword(), (-> term()), (term(), term() -> term())) ::

          term()

  def run(name, start_opts, exporter_opts, fun, result_fun)

      when is_list(start_opts) and is_list(exporter_opts) and is_function(fun, 0) and

             is_function(result_fun, 2) do

    {:ok, run} = Tracing.start_run(name, exporter_opts ++ start_opts)



    try do

      result = fun.()

      result_fun.(run, result)

    rescue

      exception ->

        Tracing.fail_run(run, exception, exporter_opts)

        reraise exception, __STACKTRACE__

    catch

      kind, reason ->

        Tracing.fail_run(run, %{kind: kind, reason: reason}, exporter_opts)

        :erlang.raise(kind, reason, __STACKTRACE__)

    end

  end

end