Merge branch 'main' into hassieb/lfe-8749-bug-custom-httpx_client-is-not-applied-to-clientasync_api-in

Author: hassiebp

.github/workflows/claude-review-maintainer-prs.yml

@@ -0,0 +1,68 @@
+name: Claude Review on Maintainer PRs
+
+on:
+  pull_request_target:
+    types:
+      - opened
+      - ready_for_review
+
+jobs:
+  comment:
+    if: github.event.pull_request.draft == false
+    runs-on: ubuntu-latest
+    permissions:
+      issues: write
+      pull-requests: write
+    steps:
+      - name: Check author permission and existing review request
+        id: check
+        uses: actions/github-script@v7
+        with:
+          script: |
+            const owner = context.repo.owner;
+            const repo = context.repo.repo;
+            const issue_number = context.payload.pull_request.number;
+            const username = context.payload.pull_request.user.login;
+
+            let permission = "none";
+            try {
+              const { data } = await github.rest.repos.getCollaboratorPermissionLevel({
+                owner,
+                repo,
+                username,
+              });
+              permission = data.permission;
+            } catch (error) {
+              if (error.status !== 404) {
+                throw error;
+              }
+            }
+
+            const canWrite = ["write", "admin"].includes(permission);
+            const comments = await github.paginate(github.rest.issues.listComments, {
+              owner,
+              repo,
+              issue_number,
+              per_page: 100,
+            });
+            const hasReviewRequest = comments.some(
+              (comment) => comment.body?.trim() === "@claude review",
+            );
+
+            core.info(
+              `PR #${issue_number} by ${username}: permission=${permission}, hasReviewRequest=${hasReviewRequest}`,
+            );
+
+            core.setOutput("should_comment", canWrite && !hasReviewRequest ? "true" : "false");
+
+      - name: Add Claude review comment
+        if: steps.check.outputs.should_comment == 'true'
+        uses: actions/github-script@v7
+        with:
+          script: |
+            await github.rest.issues.createComment({
+              owner: context.repo.owner,
+              repo: context.repo.repo,
+              issue_number: context.payload.pull_request.number,
+              body: "@claude review",
+            });

README.md

@@ -12,7 +12,7 @@
 ## Installation
 
 > [!IMPORTANT]
-> The SDK was rewritten in v3 and released in June 2025. Refer to the [v3 migration guide](https://langfuse.com/docs/sdk/python/sdk-v3#upgrade-from-v2) for instructions on updating your code.
+> The SDK was rewritten in v4 and released in March 2026. Refer to the [v4 migration guide](https://langfuse.com/docs/observability/sdk/upgrade-path/python-v3-to-v4) for instructions on updating your code.
 
 ```
 pip install langfuse

langfuse/_client/observe.py

@@ -327,7 +327,7 @@ async def async_wrapper(*args: Tuple[Any], **kwargs: Dict[str, Any]) -> Any:
                             langfuse_span_or_generation.update(output=result)
 
                         return result
-                    except Exception as e:
+                    except (Exception, asyncio.CancelledError) as e:
                         langfuse_span_or_generation.update(
                             level="ERROR", status_message=str(e) or type(e).__name__
                         )
@@ -445,7 +445,7 @@ def sync_wrapper(*args: Any, **kwargs: Any) -> Any:
                             langfuse_span_or_generation.update(output=result)
 
                         return result
-                    except Exception as e:
+                    except (Exception, asyncio.CancelledError) as e:
                         langfuse_span_or_generation.update(
                             level="ERROR", status_message=str(e) or type(e).__name__
                         )
@@ -586,7 +586,7 @@ def __next__(self) -> Any:
 
             raise  # Re-raise StopIteration
 
-        except Exception as e:
+        except (Exception, asyncio.CancelledError) as e:
             self.span.update(
                 level="ERROR", status_message=str(e) or type(e).__name__
             ).end()
@@ -653,7 +653,7 @@ async def __anext__(self) -> Any:
             self.span.update(output=output).end()
 
             raise  # Re-raise StopAsyncIteration
-        except Exception as e:
+        except (Exception, asyncio.CancelledError) as e:
             self.span.update(
                 level="ERROR", status_message=str(e) or type(e).__name__
             ).end()

langfuse/api/dataset_run_items/client.py

@@ -38,6 +38,7 @@ def create(
         observation_id: typing.Optional[str] = OMIT,
         trace_id: typing.Optional[str] = OMIT,
         dataset_version: typing.Optional[dt.datetime] = OMIT,
+        created_at: typing.Optional[dt.datetime] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> DatasetRunItem:
         """
@@ -66,6 +67,9 @@ def create(
             If provided, the experiment will use dataset items as they existed at or before this timestamp.
             If not provided, uses the latest version of dataset items.
 
+        created_at : typing.Optional[dt.datetime]
+            Optional timestamp to set the createdAt field of the dataset run item. If not provided or null, defaults to current timestamp.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -98,6 +102,7 @@ def create(
             observation_id=observation_id,
             trace_id=trace_id,
             dataset_version=dataset_version,
+            created_at=created_at,
             request_options=request_options,
         )
         return _response.data
@@ -185,6 +190,7 @@ async def create(
         observation_id: typing.Optional[str] = OMIT,
         trace_id: typing.Optional[str] = OMIT,
         dataset_version: typing.Optional[dt.datetime] = OMIT,
+        created_at: typing.Optional[dt.datetime] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> DatasetRunItem:
         """
@@ -213,6 +219,9 @@ async def create(
             If provided, the experiment will use dataset items as they existed at or before this timestamp.
             If not provided, uses the latest version of dataset items.
 
+        created_at : typing.Optional[dt.datetime]
+            Optional timestamp to set the createdAt field of the dataset run item. If not provided or null, defaults to current timestamp.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -253,6 +262,7 @@ async def main() -> None:
             observation_id=observation_id,
             trace_id=trace_id,
             dataset_version=dataset_version,
+            created_at=created_at,
             request_options=request_options,
         )
         return _response.data

langfuse/api/dataset_run_items/raw_client.py

@@ -35,6 +35,7 @@ def create(
         observation_id: typing.Optional[str] = OMIT,
         trace_id: typing.Optional[str] = OMIT,
         dataset_version: typing.Optional[dt.datetime] = OMIT,
+        created_at: typing.Optional[dt.datetime] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> HttpResponse[DatasetRunItem]:
         """
@@ -63,6 +64,9 @@ def create(
             If provided, the experiment will use dataset items as they existed at or before this timestamp.
             If not provided, uses the latest version of dataset items.
 
+        created_at : typing.Optional[dt.datetime]
+            Optional timestamp to set the createdAt field of the dataset run item. If not provided or null, defaults to current timestamp.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -81,6 +85,7 @@ def create(
                 "observationId": observation_id,
                 "traceId": trace_id,
                 "datasetVersion": dataset_version,
+                "createdAt": created_at,
             },
             request_options=request_options,
             omit=OMIT,
@@ -298,6 +303,7 @@ async def create(
         observation_id: typing.Optional[str] = OMIT,
         trace_id: typing.Optional[str] = OMIT,
         dataset_version: typing.Optional[dt.datetime] = OMIT,
+        created_at: typing.Optional[dt.datetime] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> AsyncHttpResponse[DatasetRunItem]:
         """
@@ -326,6 +332,9 @@ async def create(
             If provided, the experiment will use dataset items as they existed at or before this timestamp.
             If not provided, uses the latest version of dataset items.
 
+        created_at : typing.Optional[dt.datetime]
+            Optional timestamp to set the createdAt field of the dataset run item. If not provided or null, defaults to current timestamp.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -344,6 +353,7 @@ async def create(
                 "observationId": observation_id,
                 "traceId": trace_id,
                 "datasetVersion": dataset_version,
+                "createdAt": created_at,
             },
             request_options=request_options,
             omit=OMIT,

langfuse/api/dataset_run_items/types/create_dataset_run_item_request.py

@@ -46,6 +46,13 @@ class CreateDatasetRunItemRequest(UniversalBaseModel):
     If not provided, uses the latest version of dataset items.
     """
 
+    created_at: typing_extensions.Annotated[
+        typing.Optional[dt.datetime], FieldMetadata(alias="createdAt")
+    ] = pydantic.Field(default=None)
+    """
+    Optional timestamp to set the createdAt field of the dataset run item. If not provided or null, defaults to current timestamp.
+    """
+
     model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(
         extra="allow", frozen=True
     )

langfuse/openai.py

@@ -246,6 +246,34 @@ def wrapper(wrapped: Any, instance: Any, args: Any, kwargs: Any) -> Any:
     return _with_langfuse
 
 
+def _extract_responses_prompt(kwargs: Any) -> Any:
+    input_value = kwargs.get("input", None)
+    instructions = kwargs.get("instructions", None)
+
+    if isinstance(input_value, NotGiven):
+        input_value = None
+
+    if isinstance(instructions, NotGiven):
+        instructions = None
+
+    if instructions is None:
+        return input_value
+
+    if input_value is None:
+        return {"instructions": instructions}
+
+    if isinstance(input_value, str):
+        return [
+            {"role": "system", "content": instructions},
+            {"role": "user", "content": input_value},
+        ]
+
+    if isinstance(input_value, list):
+        return [{"role": "system", "content": instructions}, *input_value]
+
+    return {"instructions": instructions, "input": input_value}
+
+
 def _extract_chat_prompt(kwargs: Any) -> Any:
     """Extracts the user input from prompts. Returns an array of messages or dict with messages and functions"""
     prompt = {}
@@ -403,7 +431,7 @@ def _get_langfuse_data_from_kwargs(resource: OpenAiDefinition, kwargs: Any) -> A
     if resource.type == "completion":
         prompt = kwargs.get("prompt", None)
     elif resource.object == "Responses" or resource.object == "AsyncResponses":
-        prompt = kwargs.get("input", None)
+        prompt = _extract_responses_prompt(kwargs)
     elif resource.type == "chat":
         prompt = _extract_chat_prompt(kwargs)
     elif resource.type == "embedding":
@@ -539,8 +567,8 @@ def _parse_usage(usage: Optional[Any] = None) -> Any:
     for tokens_details in [
         "prompt_tokens_details",
         "completion_tokens_details",
-        "input_token_details",
-        "output_token_details",
+        "input_tokens_details",
+        "output_tokens_details",
     ]:
         if tokens_details in usage_dict and usage_dict[tokens_details] is not None:
             tokens_details_dict = (

langfuse/version.py

@@ -1,3 +1,3 @@
 """@private"""
 
-__version__ = "4.0.0"
+__version__ = "4.0.1"

poetry.lock

@@ -1,7 +1,7 @@
 [tool.poetry]
 name = "langfuse"
 
-version = "4.0.0"
+version = "4.0.1"
 description = "A client library for accessing langfuse"
 authors = ["langfuse <developers@langfuse.com>"]
 license = "MIT"
@@ -14,7 +14,7 @@ pydantic = "^2"
 backoff = ">=1.10.0"
 openai = { version = ">=0.27.8", optional = true }
 wrapt = "^1.14"
-packaging = ">=23.2,<26.0"
+packaging = ">=23.2,<27.0"
 opentelemetry-api = "^1.33.1"
 opentelemetry-sdk = "^1.33.1"
 opentelemetry-exporter-otlp-proto-http = "^1.33.1"