Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions lib/langfuse/client.ex
Original file line number Diff line number Diff line change
Expand Up @@ -999,9 +999,7 @@ defmodule Langfuse.Client do
def delete(path) do
config = Config.get()

unless Config.configured?() do
{:error, :not_configured}
else
if Config.configured?() do
url = config.host <> path

case Req.delete(url, auth: {:basic, "#{config.public_key}:#{config.secret_key}"}) do
Expand All @@ -1014,6 +1012,8 @@ defmodule Langfuse.Client do
{:error, reason} ->
{:error, reason}
end
else
{:error, :not_configured}
end
end

Expand All @@ -1030,9 +1030,7 @@ defmodule Langfuse.Client do
def patch(path, body) do
config = Config.get()

unless Config.configured?() do
{:error, :not_configured}
else
if Config.configured?() do
url = config.host <> path

case Req.patch(url,
Expand All @@ -1048,6 +1046,8 @@ defmodule Langfuse.Client do
{:error, reason} ->
{:error, reason}
end
else
{:error, :not_configured}
end
end

Expand Down
2 changes: 1 addition & 1 deletion lib/langfuse/event.ex
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ defmodule Langfuse.Event do

"""

alias Langfuse.{Ingestion, Trace, Span}
alias Langfuse.{Ingestion, Span, Trace}

@typedoc "Log level for the observation."
@type level :: :debug | :default | :warning | :error
Expand Down
2 changes: 1 addition & 1 deletion lib/langfuse/generation.ex
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ defmodule Langfuse.Generation do

"""

alias Langfuse.{Ingestion, Trace, Span}
alias Langfuse.{Ingestion, Span, Trace}

@typedoc "Log level for the observation."
@type level :: :debug | :default | :warning | :error
Expand Down
12 changes: 6 additions & 6 deletions lib/langfuse/http.ex
Original file line number Diff line number Diff line change
Expand Up @@ -112,10 +112,10 @@ defmodule Langfuse.HTTP do
def get(path, params \\ []) do
config = Config.get()

unless Config.configured?() do
{:error, :not_configured}
else
if Config.configured?() do
request(:get, path, config, params: params)
else
{:error, :not_configured}
end
end

Expand All @@ -129,10 +129,10 @@ defmodule Langfuse.HTTP do
def post(path, body) do
config = Config.get()

unless Config.configured?() do
{:error, :not_configured}
else
if Config.configured?() do
request(:post, path, config, json: body)
else
{:error, :not_configured}
end
end

Expand Down
2 changes: 1 addition & 1 deletion lib/langfuse/open_telemetry.ex
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ defmodule Langfuse.OpenTelemetry do

"""

alias Langfuse.OpenTelemetry.{AttributeMapper, TraceContext, Setup}
alias Langfuse.OpenTelemetry.{AttributeMapper, Setup, TraceContext}

@doc """
Extracts trace and span IDs from an OpenTelemetry span context.
Expand Down
14 changes: 6 additions & 8 deletions lib/langfuse/open_telemetry/setup.ex
Original file line number Diff line number Diff line change
Expand Up @@ -206,13 +206,11 @@ defmodule Langfuse.OpenTelemetry.Setup do
end

defp safe_get_tracer_provider do
try do
:otel_tracer_provider.resource()
true
rescue
_ -> false
catch
_, _ -> false
end
:otel_tracer_provider.resource()
true
rescue
_ -> false
catch
_, _ -> false
end
end
6 changes: 3 additions & 3 deletions lib/langfuse/open_telemetry/span_processor.ex
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,8 @@ defmodule Langfuse.OpenTelemetry.SpanProcessor do

@behaviour :otel_span_processor

alias Langfuse.OpenTelemetry.AttributeMapper
alias Langfuse.Ingestion
alias Langfuse.OpenTelemetry.AttributeMapper

@typedoc "Processor configuration options."
@type config :: %{
Expand Down Expand Up @@ -119,7 +119,7 @@ defmodule Langfuse.OpenTelemetry.SpanProcessor do
parent_span_id_hex = format_span_id(parent_span_id)

mapped_attrs = AttributeMapper.map_attributes(attributes)
is_generation = is_generation?(attributes, mapped_attrs)
is_generation = generation?(attributes, mapped_attrs)
is_root = is_nil(parent_span_id) or parent_span_id == 0

if is_root do
Expand Down Expand Up @@ -170,7 +170,7 @@ defmodule Langfuse.OpenTelemetry.SpanProcessor do

defp normalize_span(_), do: nil

defp is_generation?(attributes, mapped_attrs) do
defp generation?(attributes, mapped_attrs) do
Map.has_key?(mapped_attrs, :model) or
has_genai_attribute?(attributes)
end
Expand Down
16 changes: 6 additions & 10 deletions lib/langfuse/prompt.ex
Original file line number Diff line number Diff line change
Expand Up @@ -365,19 +365,15 @@ defmodule Langfuse.Prompt do
end

defp delete_cache_key(key) do
try do
:ets.delete(:langfuse_prompt_cache, key)
rescue
ArgumentError -> :ok
end
:ets.delete(:langfuse_prompt_cache, key)
rescue
ArgumentError -> :ok
end

defp delete_cache_by_name(name) do
try do
:ets.match_delete(:langfuse_prompt_cache, {{name, :_, :_}, :_, :_})
rescue
ArgumentError -> :ok
end
:ets.match_delete(:langfuse_prompt_cache, {{name, :_, :_}, :_, :_})
rescue
ArgumentError -> :ok
end

defp get_cached(key) do
Expand Down
2 changes: 1 addition & 1 deletion lib/langfuse/score.ex
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ defmodule Langfuse.Score do

"""

alias Langfuse.{Ingestion, Trace, Span, Generation}
alias Langfuse.{Generation, Ingestion, Span, Trace}

@typedoc "Score data type classification."
@type data_type :: :numeric | :categorical | :boolean
Expand Down
2 changes: 1 addition & 1 deletion test/langfuse/error_test.exs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
defmodule Langfuse.ErrorTest do
use ExUnit.Case, async: true

alias Langfuse.Error.{ConfigError, APIError, ValidationError, PromptNotFoundError}
alias Langfuse.Error.{APIError, ConfigError, PromptNotFoundError, ValidationError}

describe "ConfigError" do
test "message with key and custom message" do
Expand Down
2 changes: 1 addition & 1 deletion test/langfuse/event_test.exs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
defmodule Langfuse.EventTest do
use ExUnit.Case, async: true

alias Langfuse.{Event, Trace, Span}
alias Langfuse.{Event, Span, Trace}

describe "new/2" do
test "creates an event from a trace" do
Expand Down
11 changes: 6 additions & 5 deletions test/langfuse/generation_test.exs
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
defmodule Langfuse.GenerationTest do
use ExUnit.Case, async: false

alias Langfuse.{Generation, Trace, Span}
alias Langfuse.{Generation, Span, Trace}
alias Langfuse.Test.Helpers

describe "new/2" do
test "creates a generation from a trace" do
Expand Down Expand Up @@ -139,7 +140,7 @@ defmodule Langfuse.GenerationTest do
describe "event capture" do
test "new/2 sends generation-create event" do
{_gen, events} =
Langfuse.Test.Helpers.capture_events(fn ->
Helpers.capture_events(fn ->
trace = Trace.new(name: "test-trace")
Generation.new(trace, name: "llm-call", model: "gpt-4")
end)
Expand All @@ -152,7 +153,7 @@ defmodule Langfuse.GenerationTest do

test "update/2 sends generation-update event" do
{_gen, events} =
Langfuse.Test.Helpers.capture_events(fn ->
Helpers.capture_events(fn ->
trace = Trace.new(name: "test-trace")
gen = Generation.new(trace, name: "llm-call")
Generation.update(gen, output: %{content: "response"})
Expand All @@ -165,7 +166,7 @@ defmodule Langfuse.GenerationTest do

test "end_generation/1 sends generation-update event with end_time" do
{_gen, events} =
Langfuse.Test.Helpers.capture_events(fn ->
Helpers.capture_events(fn ->
trace = Trace.new(name: "test-trace")
gen = Generation.new(trace, name: "llm-call")
Generation.end_generation(gen)
Expand All @@ -178,7 +179,7 @@ defmodule Langfuse.GenerationTest do

test "events include required fields" do
{_gen, events} =
Langfuse.Test.Helpers.capture_events(fn ->
Helpers.capture_events(fn ->
trace = Trace.new(name: "test-trace")
Generation.new(trace, name: "llm-call")
end)
Expand Down
2 changes: 1 addition & 1 deletion test/langfuse/score_test.exs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
defmodule Langfuse.ScoreTest do
use ExUnit.Case, async: false

alias Langfuse.{Score, Trace, Span, Generation}
alias Langfuse.{Generation, Score, Span, Trace}
import Langfuse.Test.Helpers

describe "create/2" do
Expand Down
Loading
Loading