fix(scores): parse session ID correctly

Author: hassiebp

langfuse/_client/client.py

@@ -1818,7 +1818,7 @@ def create_score(
         try:
             new_body = ScoreBody(
                 id=score_id,
-                session_id=session_id,
+                sessionId=session_id,
                 datasetRunId=dataset_run_id,
                 traceId=trace_id,
                 observationId=observation_id,

langfuse/_utils/request.py

@@ -48,9 +48,8 @@ def generate_headers(self) -> dict:
 
     def batch_post(self, **kwargs: Any) -> httpx.Response:
         """Post the `kwargs` to the batch API endpoint for events"""
-        logger.debug("uploading data: %s", kwargs)
-
         res = self.post(**kwargs)
+
         return self._process_response(
             res, success_message="data uploaded successfully", return_json=False
         )

tests/test_core_sdk.py

@@ -118,6 +118,51 @@ def test_invalid_score_data_does_not_raise_exception():
     # We can't assert queue size in OTEL implementation, but we can verify it completes without exception
 
 
+def test_create_session_score():
+    langfuse = Langfuse()
+    api_wrapper = LangfuseAPI()
+
+    session_id = 'my-session'
+
+    # Create a span and set trace properties
+    with langfuse.start_as_current_observation(name="test-span") as span:
+        with propagate_attributes(
+            trace_name="this-is-so-great-new",
+            user_id="test",
+            metadata={"test": "test"},
+            session_id=session_id
+        ):
+            # Get trace ID for later use
+            trace_id = span.trace_id
+
+    # Ensure data is sent
+    langfuse.flush()
+    sleep(2)
+
+    # Create a numeric score
+    score_id = create_uuid()
+    print('score ID', score_id)
+    langfuse.create_score(
+        score_id=score_id,
+        session_id=session_id,
+        name="this-is-a-score",
+        value=1,
+    )
+
+
+    # Ensure data is sent
+    langfuse.flush()
+    sleep(2)
+
+    # Retrieve and verify
+    score = langfuse.api.scores.get_by_id(score_id)
+
+    # find the score by name (server may transform the id format)
+    assert score is not None
+    assert score.value == 1
+    assert score.data_type == "NUMERIC"
+    assert score.session_id == session_id
+
 def test_create_numeric_score():
     langfuse = Langfuse()
     api_wrapper = LangfuseAPI()