o 畢hj@sddlmZddlmZmZmZmZmZmZm Z ddl m Z ddl m Z ddlZddlmZddlmZmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lm Z m!Z!dd l"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)m*Z+m,Z-m.Z/ddl0m1Z1ddl2m3Z3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBddlCmDZDddlEmFZFddgZGGdddeZHGdddeZIGd d!d!ZJGd"d#d#ZKGd$d%d%ZLGd&d'd'ZMdS)() annotations)DictListTypeUnionIterableOptionalcast)partial)LiteralN)_legacy_response) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)Stream)completion_create_params)make_request_options)ResponseFormatTvalidate_input_toolsparse_chat_completiontype_to_response_format_param) ChatModel)ChatCompletionStreamManager AsyncChatCompletionStreamManager)ChatCompletion)ChatCompletionChunk)ParsedChatCompletion)ChatCompletionModality)ChatCompletionToolParam)ChatCompletionAudioParam)ChatCompletionMessageParam) ChatCompletionStreamOptionsParam)#ChatCompletionToolChoiceOptionParam CompletionsAsyncCompletionsc@eZdZedGddZedHddZeeeeeeeeeeeeeeeeeeeeeeeeeddded dIdAdBZeeeeeeeeeeeeeeeeeeeeeeeeeddded dJdEdFZdS)Kr-returnCompletionsWithRawResponsecCt|Sa This property can be used as a prefix for any HTTP method call to return the the raw response object instead of the parsed content. For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers )r1selfr6^/var/www/html/zoom/venv/lib/python3.10/site-packages/openai/resources/beta/chat/completions.pywith_raw_response*zCompletions.with_raw_response CompletionsWithStreamingResponsecCr2z An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/openai/openai-python#with_streaming_response )r:r4r6r6r7with_streaming_response4z#Completions.with_streaming_responseNaudioresponse_formatfrequency_penalty function_call functions logit_biaslogprobsmax_completion_tokens max_tokensmetadata modalitiesnparallel_tool_callspresence_penaltyseed service_tierstopstorestream_options temperature tool_choicetools top_logprobstop_puser extra_headers extra_query extra_bodytimeoutmessages$Iterable[ChatCompletionMessageParam]modelUnion[str, ChatModel]r?-Optional[ChatCompletionAudioParam] | NotGivenr@ type[ResponseFormatT] | NotGivenrAOptional[float] | NotGivenrB0completion_create_params.FunctionCall | NotGivenrC6Iterable[completion_create_params.Function] | NotGivenrD#Optional[Dict[str, int]] | NotGivenrEOptional[bool] | NotGivenrFOptional[int] | NotGivenrGrH#Optional[Dict[str, str]] | NotGivenrI1Optional[List[ChatCompletionModality]] | NotGivenrJrKbool | NotGivenrLrMrN/Optional[Literal['auto', 'default']] | NotGivenrO*Union[Optional[str], List[str]] | NotGivenrPrQ5Optional[ChatCompletionStreamOptionsParam] | NotGivenrRrS.ChatCompletionToolChoiceOptionParam | NotGivenrT,Iterable[ChatCompletionToolParam] | NotGivenrUrVrWstr | NotGivenrXHeaders | NonerY Query | NonerZ Body | Noner['float | httpx.Timeout | None | NotGiven%ParsedChatCompletion[ResponseFormatT]c!stddi|p i}d fdd } |jd tid |d |d |d |d|d|d|d| d| d| d| d| d|d|d|dtd||||d||||||d tjt||||| dttt t t ddS)!aWrapper over the `client.chat.completions.create()` method that provides richer integrations with Python specific types & returns a `ParsedChatCompletion` object, which is a subclass of the standard `ChatCompletion` class. You can pass a pydantic model to this method and it will automatically convert the model into a JSON schema, send it to the API and parse the response content back into the given model. This method will also automatically parse `function` tool calls if: - You use the `openai.pydantic_function_tool()` helper method - You mark your tool schema with `"strict": True` Example usage: ```py from pydantic import BaseModel from openai import OpenAI class Step(BaseModel): explanation: str output: str class MathResponse(BaseModel): steps: List[Step] final_answer: str client = OpenAI() completion = client.beta.chat.completions.parse( model="gpt-4o-2024-08-06", messages=[ {"role": "system", "content": "You are a helpful math tutor."}, {"role": "user", "content": "solve 8x + 31 = 2"}, ], response_format=MathResponse, ) message = completion.choices[0].message if message.parsed: print(message.parsed.steps) print("answer: ", message.parsed.final_answer) ``` X-Stainless-Helper-Methodbeta.chat.completions.parseraw_completionr$r0ruct|dSN)r@chat_completion input_tools_parse_chat_completionrxr@rTr6r7parser z!Completions.parse..parser/chat/completionsr\r^r?rArBrCrDrErFrGrHrIrJrKrLr@rMF) rNrOrPstreamrQrRrSrTrUrVrWrXrYrZr[ post_parserbodyoptionscast_torNrxr$r0ru) _validate_input_tools_postr_type_to_response_formatrCompletionCreateParamsrr rr&rr$!r5r\r^r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[rr6rr7parse=sO     ! zCompletions.parseJcompletion_create_params.ResponseFormat | type[ResponseFormatT] | NotGiven,ChatCompletionStreamManager[ResponseFormatT]c!Csddi|pi}t|jjjjfid|d|d|dddt|d |d |d |d |d | d| d| d| d| d|d|d|d|d|d|d|d|d|d|d|d|d|d|d |d!|d"|d#|} t| ||d$S)%aWrapper over the `client.chat.completions.create(stream=True)` method that provides a more granular event API and automatic accumulation of each delta. This also supports all of the parsing utilities that `.parse()` does. Unlike `.create(stream=True)`, the `.stream()` method requires usage within a context manager to prevent accidental leakage of the response: ```py with client.beta.chat.completions.stream( model="gpt-4o-2024-08-06", messages=[...], ) as stream: for event in stream: if event.type == "content.delta": print(event.delta, flush=True, end="") ``` When the context manager is entered, a `ChatCompletionStream` instance is returned which, like `.create(stream=True)` is an iterator. The full list of events that are yielded by the iterator are outlined in [these docs](https://github.com/openai/openai-python/blob/main/helpers.md#chat-completions-events). When the context manager exits, the response will be closed, however the `stream` instance is still available outside the context manager. rvbeta.chat.completions.streamr\r^r?rTr@rArBrCrDrErFrGrHrIrJrKrLrMrNrPrOrQrRrSrTrUrVrWrXrYrZr[r@r|)r _clientchat completionscreaterr"!r5r\r^r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[ api_requestr6r6r7rs<       !#zCompletions.stream)r0r1)r0r:@r\r]r^r_r?r`r@rarArbrBrcrCrdrDrerErfrFrgrGrgrHrhrIrirJrgrKrjrLrbrMrgrNrkrOrlrPrfrQrmrRrbrSrnrTrorUrgrVrbrWrprXrqrYrrrZrsr[rtr0ru)@r\r]r^r_r?r`r@rrArbrBrcrCrdrDrerErfrFrgrGrgrHrhrIrirJrgrKrjrLrbrMrgrNrkrOrlrPrfrQrmrRrbrSrnrTrorUrgrVrbrWrprXrqrYrrrZrsr[rtr0r __name__ __module__ __qualname__rr8r<rrrr6r6r6r7r-)   c@r/)Kr.r0AsyncCompletionsWithRawResponsecCr2r3)rr4r6r6r7r85r9z"AsyncCompletions.with_raw_response%AsyncCompletionsWithStreamingResponsecCr2r;)rr4r6r6r7r<?r=z(AsyncCompletions.with_streaming_responseNr>r\r]r^r_r?r`r@rarArbrBrcrCrdrDrerErfrFrgrGrHrhrIrirJrKrjrLrMrNrkrOrlrPrQrmrRrSrnrTrorUrVrWrprXrqrYrrrZrsr[rtruc!stddi|p i}d fdd } |jd tid |d |d |d |d|d|d|d| d| d| d| d| d|d|d|dtd||||d||||||d tjIdHt||||| dttt t t ddIdHS)!aWrapper over the `client.chat.completions.create()` method that provides richer integrations with Python specific types & returns a `ParsedChatCompletion` object, which is a subclass of the standard `ChatCompletion` class. You can pass a pydantic model to this method and it will automatically convert the model into a JSON schema, send it to the API and parse the response content back into the given model. This method will also automatically parse `function` tool calls if: - You use the `openai.pydantic_function_tool()` helper method - You mark your tool schema with `"strict": True` Example usage: ```py from pydantic import BaseModel from openai import AsyncOpenAI class Step(BaseModel): explanation: str output: str class MathResponse(BaseModel): steps: List[Step] final_answer: str client = AsyncOpenAI() completion = await client.beta.chat.completions.parse( model="gpt-4o-2024-08-06", messages=[ {"role": "system", "content": "You are a helpful math tutor."}, {"role": "user", "content": "solve 8x + 31 = 2"}, ], response_format=MathResponse, ) message = completion.choices[0].message if message.parsed: print(message.parsed.steps) print("answer: ", message.parsed.final_answer) ``` rvrwrxr$r0rucryrzr}rrr6r7rrz&AsyncCompletions.parse..parserrr\r^r?rArBrCrDrErFrGrHrIrJrKrLr@rMF) rNrPrOrrQrRrSrTrUrVrWNrrr) rrrrrrrr rr&rr$rr6rr7rHsO     !  zAsyncCompletions.parser1AsyncChatCompletionStreamManager[ResponseFormatT]c!Cst|ddi|p i}|jjjjd&id|d|d|dddt|d |d |d |d |d | d| d| d| d| d|d|d|d|d|d|d|d|d|d|d|d|d|d|d |d!|d"|d#|} t| ||d$S)'aWrapper over the `client.chat.completions.create(stream=True)` method that provides a more granular event API and automatic accumulation of each delta. This also supports all of the parsing utilities that `.parse()` does. Unlike `.create(stream=True)`, the `.stream()` method requires usage within a context manager to prevent accidental leakage of the response: ```py async with client.beta.chat.completions.stream( model="gpt-4o-2024-08-06", messages=[...], ) as stream: async for event in stream: if event.type == "content.delta": print(event.delta, flush=True, end="") ``` When the context manager is entered, an `AsyncChatCompletionStream` instance is returned which, like `.create(stream=True)` is an async iterator. The full list of events that are yielded by the iterator are outlined in [these docs](https://github.com/openai/openai-python/blob/main/helpers.md#chat-completions-events). When the context manager exits, the response will be closed, however the `stream` instance is still available outside the context manager. rvrr\r^r?rTr@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[rNr6)rrrrrrr#rr6r6r7rs;      "zAsyncCompletions.stream)r0r)r0rr)@r\r]r^r_r?r`r@rrArbrBrcrCrdrDrerErfrFrgrGrgrHrhrIrirJrgrKrjrLrbrMrgrNrkrOrlrPrfrQrmrRrbrSrnrTrorUrgrVrbrWrprXrqrYrrrZrsr[rtr0rrr6r6r6r7r.4rc@eZdZdddZdS) r1rr-r0NonecC||_t|j|_dSN) _completionsr to_raw_response_wrapperrr5rr6r6r7__init__A z#CompletionsWithRawResponse.__init__Nrr-r0rrrrrr6r6r6r7r1@r1c@r) rrr.r0rcCrr)rr async_to_raw_response_wrapperrrr6r6r7rJrz(AsyncCompletionsWithRawResponse.__init__Nrr.r0rrr6r6r6r7rIrrc@r) r:rr-r0rcC||_t|j|_dSr)rrrrr6r6r7rS z)CompletionsWithStreamingResponse.__init__Nrrr6r6r6r7r:Rrr:c@r) rrr.r0rcCrr)rrrrr6r6r7r\rz.AsyncCompletionsWithStreamingResponse.__init__Nrrr6r6r6r7r[rr)N __future__rtypingrrrrrrr functoolsr typing_extensionsr httpxr _typesrrrrr_utilsrr_compatr _resourcerr _responserr _streamingr types.chatr _base_clientr lib._parsingrrrrr~r rtypes.chat_modelr!lib.streaming.chatr"r#types.chat.chat_completionr$ types.chat.chat_completion_chunkr%!types.chat.parsed_chat_completionr&#types.chat.chat_completion_modalityr'%types.chat.chat_completion_tool_paramr(&types.chat.chat_completion_audio_paramr)(types.chat.chat_completion_message_paramr*/types.chat.chat_completion_stream_options_paramr+3types.chat.chat_completion_tool_choice_option_paramr,__all__r-r.r1rr:rr6r6r6r7sJ $