From 96d1b9279de4753ff80e663f6429d75a3f0a7e55 Mon Sep 17 00:00:00 2001 From: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com> Date: Mon, 15 Dec 2025 09:59:37 +0100 Subject: [PATCH 1/2] fix(client): flush on shutdown --- langfuse/_client/resource_manager.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/langfuse/_client/resource_manager.py b/langfuse/_client/resource_manager.py index aa9c7ce89..08c008234 100644 --- a/langfuse/_client/resource_manager.py +++ b/langfuse/_client/resource_manager.py @@ -415,11 +415,7 @@ def shutdown(self) -> None: # Unregister the atexit handler first atexit.unregister(self.shutdown) - if self.tracer_provider is not None and not isinstance( - self.tracer_provider, otel_trace_api.ProxyTracerProvider - ): - self.tracer_provider.force_flush() - + self.flush() self._stop_and_join_consumer_threads() From bcc58800731214e866d33c0562e79c4e044ea8d7 Mon Sep 17 00:00:00 2001 From: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com> Date: Tue, 16 Dec 2025 15:05:53 +0100 Subject: [PATCH 2/2] push --- tests/test_datasets.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/test_datasets.py b/tests/test_datasets.py index c3ad7a318..c1b81868d 100644 --- a/tests/test_datasets.py +++ b/tests/test_datasets.py @@ -50,6 +50,7 @@ def test_create_dataset_item(): source_trace_id=generation.trace_id, ) langfuse.create_dataset_item( + input="Hello", dataset_name=name, ) @@ -67,7 +68,7 @@ def test_create_dataset_item(): assert dataset.items[1].source_trace_id == generation.trace_id assert dataset.items[1].dataset_name == name - assert dataset.items[0].input is None + assert dataset.items[0].input == "Hello" assert dataset.items[0].expected_output is None assert dataset.items[0].metadata is None assert dataset.items[0].source_observation_id is None