Skip to content
Open
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 langfuse/api/core/http_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -163,12 +163,12 @@ def maybe_filter_request_body(
omit: typing.Optional[typing.Any],
) -> typing.Optional[typing.Any]:
if data is None:
return (
jsonable_encoder(request_options.get("additional_body_parameters", {}))
or {}
if request_options is not None
else None
)
if request_options is None:
return None
additional_body_parameters = request_options.get("additional_body_parameters")
if not additional_body_parameters:
return None
return jsonable_encoder(additional_body_parameters)
elif not isinstance(data, typing.Mapping):
data_content = jsonable_encoder(data)
else:
Expand Down
37 changes: 37 additions & 0 deletions tests/test_http_client.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,37 @@
from langfuse.api.core.http_client import get_request_body


def test_get_request_body_skips_empty_body_when_no_additional_parameters() -> None:
json_body, data_body = get_request_body(
json=None,
data=None,
request_options={"timeout_in_seconds": 30},
omit=None,
)

assert json_body is None
assert data_body is None


def test_get_request_body_includes_additional_body_parameters() -> None:
json_body, data_body = get_request_body(
json=None,
data=None,
request_options={"additional_body_parameters": {"foo": "bar"}},
omit=None,
)

assert json_body == {"foo": "bar"}
assert data_body is None


def test_get_request_body_skips_empty_additional_body_parameters() -> None:
json_body, data_body = get_request_body(
json=None,
data=None,
request_options={"additional_body_parameters": {}},
omit=None,
)

assert json_body is None
assert data_body is None