Skip to content

Commit 7d31d85

Browse files
Align streaming adapter with OpenAI raw_stream contract
1 parent 78cdbb1 commit 7d31d85

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

langfuse/openai.py

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -842,7 +842,7 @@ def _wrap(
842842
if _is_streaming_response(openai_response):
843843
return LangfuseResponseGeneratorSync(
844844
resource=open_ai_resource,
845-
response=openai_response,
845+
stream=openai_response,
846846
generation=generation,
847847
)
848848

@@ -913,7 +913,7 @@ async def _wrap_async(
913913
if _is_streaming_response(openai_response):
914914
return LangfuseResponseGeneratorAsync(
915915
resource=open_ai_resource,
916-
response=openai_response,
916+
stream=openai_response,
917917
generation=generation,
918918
)
919919

@@ -977,19 +977,20 @@ def __init__(
977977
self,
978978
*,
979979
resource: Any,
980-
response: Any,
980+
stream: Any,
981981
generation: Any,
982982
) -> None:
983983
self.items: list[Any] = []
984984

985985
self.resource = resource
986-
self.response = response
986+
self.stream = stream
987+
self.response = stream.response
987988
self.generation = generation
988989
self.completion_start_time: Optional[datetime] = None
989990

990991
def __iter__(self) -> Any:
991992
try:
992-
for i in self.response:
993+
for i in self.stream:
993994
self.items.append(i)
994995

995996
if self.completion_start_time is None:
@@ -1001,7 +1002,7 @@ def __iter__(self) -> Any:
10011002

10021003
def __next__(self) -> Any:
10031004
try:
1004-
item = self.response.__next__()
1005+
item = self.stream.__next__()
10051006
self.items.append(item)
10061007

10071008
if self.completion_start_time is None:
@@ -1048,19 +1049,20 @@ def __init__(
10481049
self,
10491050
*,
10501051
resource: Any,
1051-
response: Any,
1052+
stream: Any,
10521053
generation: Any,
10531054
) -> None:
10541055
self.items: list[Any] = []
10551056

10561057
self.resource = resource
1057-
self.response = response
1058+
self.stream = stream
1059+
self.response = stream.response
10581060
self.generation = generation
10591061
self.completion_start_time: Optional[datetime] = None
10601062

10611063
async def __aiter__(self) -> Any:
10621064
try:
1063-
async for i in self.response:
1065+
async for i in self.stream:
10641066
self.items.append(i)
10651067

10661068
if self.completion_start_time is None:
@@ -1072,7 +1074,7 @@ async def __aiter__(self) -> Any:
10721074

10731075
async def __anext__(self) -> Any:
10741076
try:
1075-
item = await self.response.__anext__()
1077+
item = await self.stream.__anext__()
10761078
self.items.append(item)
10771079

10781080
if self.completion_start_time is None:

0 commit comments

Comments
 (0)