o j@sddlmZddlmZmZmZddlmZddlm Z ddl Z ddl m Z dd l mZmZmZmZmZmZdd lmZmZmZmZmZmZdd lmZmZmZmZm Z dd l!m"Z"m#Z#m$Z$dd l%mZmZddl&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7ddl8m9Z9ddl:m;Z;mZ>m?Z?m@Z@ddlAmZmZddlBmCZCddgZDGddde)ZEGddde*ZFGdddZGGdddZHGdd d ZIGd!d"d"ZJdS)#) annotations)IterableOptionaloverload)partial)LiteralN)_legacy_response)Runs AsyncRunsRunsWithRawResponseAsyncRunsWithRawResponseRunsWithStreamingResponseAsyncRunsWithStreamingResponse)Messages AsyncMessagesMessagesWithRawResponseAsyncMessagesWithRawResponseMessagesWithStreamingResponse"AsyncMessagesWithStreamingResponse) NOT_GIVENBodyQueryHeadersNotGiven) required_argsmaybe_transformasync_maybe_transform)r r )cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)Stream AsyncStream)Thread ThreadDeletedAssistantStreamEventthread_create_paramsthread_update_paramsthread_create_and_run_params)make_request_options)AssistantEventHandlerAssistantEventHandlerTAssistantStreamManagerAsyncAssistantEventHandlerAsyncAssistantEventHandlerTAsyncAssistantStreamManager)rr)RunThreads AsyncThreadsc @eZdZedLddZedMddZedNd d ZedOd d ZeedddeddPddZ dddeddQd"d#Z eddded$dRd%d&Z dddeddSd(d)Z e eeeeeeddded* dTd6d7Ze eeeeeddded8 dUd;d7Ze eeeeeddded8 dVd>d7Zed+gd+d/geeeeeeddded* dWd@d7Ze eeeeeddded8 dXdBdCZe eeeeeddded8 dYdGdCZeeeeeddddedH dZdKdCZdS)[r4returnr cC t|jSN)r _clientselfr=k/var/www/html/fyndo/pharma/fyndo/venv/lib/python3.10/site-packages/openai/resources/beta/threads/threads.pyrunsA z Threads.runsrcCr8r9)rr:r;r=r=r>messagesEr@zThreads.messagesThreadsWithRawResponsecCt|Sr9)rBr;r=r=r>with_raw_responseIzThreads.with_raw_responseThreadsWithStreamingResponsecCrCr9)rFr;r=r=r>with_streaming_responseMrEzThreads.with_streaming_responseNrAmetadata extra_headers extra_query extra_bodytimeoutrA1Iterable[thread_create_params.Message] | NotGivenrIOptional[object] | NotGivenrJHeaders | NonerK Query | NonerL Body | NonerM'float | httpx.Timeout | None | NotGivenr&c Cs<ddi|pi}|jdt||dtjt||||dtdS)  Create a thread. Args: messages: A list of [messages](https://platform.openai.com/docs/api-reference/messages) to start the thread with. metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format. Keys can be a maximum of 64 characters long and values can be a maxium of 512 characters long. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds OpenAI-Beta assistants=v1/threadsrArIrJrKrLrMbodyoptionscast_to)_postrr)ThreadCreateParamsr,r&r<rArIrJrKrLrMr=r=r>createQs zThreads.createrY thread_idstrcCD|s td|ddi|pi}|jd|t||||dtdS)G Retrieves a thread. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds 8Expected a non-empty value for `thread_id` but received rUrV /threads/rYr\r] ValueError_getr,r&r<rbrJrKrLrMr=r=r>retrievezThreads.retrieverIrJrKrLrMc CsR|s td|ddi|pi}|jd|td|itjt||||dtdS) Modifies a thread. Args: metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format. Keys can be a maximum of 64 characters long and values can be a maxium of 512 characters long. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rfrUrVrgrIrYrZ)rjr^rr*ThreadUpdateParamsr,r&r<rbrIrJrKrLrMr=r=r>updateszThreads.updater'cCrd)D Delete a thread. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rfrUrVrgrYrhrj_deleter,r'rlr=r=r>deleternzThreads.delete instructionsrImodelstreamthreadtoolsrJrKrLrM assistant_idryOptional[str] | NotGivenrzr{#Optional[Literal[False]] | NotGivenr|.thread_create_and_run_params.Thread | NotGivenr}@Optional[Iterable[thread_create_and_run_params.Tool]] | NotGivenr3c CdSa Create a thread and run it in one request. Args: assistant_id: The ID of the [assistant](https://platform.openai.com/docs/api-reference/assistants) to use to execute this run. instructions: Override the default system message of the assistant. This is useful for modifying the behavior on a per-run basis. metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format. Keys can be a maximum of 64 characters long and values can be a maxium of 512 characters long. model: The ID of the [Model](https://platform.openai.com/docs/api-reference/models) to be used to execute this run. If a value is provided here, it will override the model associated with the assistant. If not, the model associated with the assistant will be used. stream: If `true`, returns a stream of events that happen during the Run as server-sent events, terminating when the Run enters a terminal state with a `data: [DONE]` message. thread: If no thread is provided, an empty thread will be created. tools: Override the tools the assistant can use for this run. This is useful for modifying the behavior on a per-run basis. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds Nr= r<r~ryrIrzr{r|r}rJrKrLrMr=r=r>create_and_run8zThreads.create_and_run ryrIrzr|r}rJrKrLrM Literal[True]Stream[AssistantStreamEvent]c Cra Create a thread and run it in one request. Args: assistant_id: The ID of the [assistant](https://platform.openai.com/docs/api-reference/assistants) to use to execute this run. stream: If `true`, returns a stream of events that happen during the Run as server-sent events, terminating when the Run enters a terminal state with a `data: [DONE]` message. instructions: Override the default system message of the assistant. This is useful for modifying the behavior on a per-run basis. metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format. Keys can be a maximum of 64 characters long and values can be a maxium of 512 characters long. model: The ID of the [Model](https://platform.openai.com/docs/api-reference/models) to be used to execute this run. If a value is provided here, it will override the model associated with the assistant. If not, the model associated with the assistant will be used. thread: If no thread is provided, an empty thread will be created. tools: Override the tools the assistant can use for this run. This is useful for modifying the behavior on a per-run basis. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds Nr= r<r~r{ryrIrzr|r}rJrKrLrMr=r=r>r(rbool"Run | Stream[AssistantStreamEvent]c Crrr=rr=r=r>rbr3Optional[Literal[False]] | Literal[True] | NotGivenc CsRddi|pi}|jdt|||||||dtjt|| | | dt|p#dttdSNrUrV /threads/runsr~ryrIrzr{r|r}rYFr[r\r]r{ stream_cls)r^rr+ThreadCreateAndRunParamsr,r3r$r(rr=r=r>rs*  -AssistantStreamManager[AssistantEventHandler]c Cr'Create a thread and stream the run backNr= r<r~ryrIrzr|r}rJrKrLrMr=r=r>create_and_run_streamzThreads.create_and_run_stream event_handlerr..AssistantStreamManager[AssistantEventHandlerT]c Crrr= r<r~ryrIrzr|r}rrJrKrLrMr=r=r>r ryrIrzr|r}rrJrKrLrMAssistantEventHandlerT | None^AssistantStreamManager[AssistantEventHandler] | AssistantStreamManager[AssistantEventHandlerT]c Csndd|rdndd|p i}t|jdt||||d||dtjt|| | | d tdttd } t | |p4t d S rrVzthreads.create_and_run_streamtruefalse)rUzX-Stainless-Stream-Helperz X-Stainless-Custom-Event-HandlerrTrrYr)r) rr^rr+rr,r3r$r(r/r-) r<r~ryrIrzr|r}rrJrKrLrM make_requestr=r=r>rs8   )r7r )r7r)r7rB)r7rFrArNrIrOrJrPrKrQrLrRrMrSr7r& rbrcrJrPrKrQrLrRrMrSr7r&rbrcrIrOrJrPrKrQrLrRrMrSr7r& rbrcrJrPrKrQrLrRrMrSr7r'r~rcryrrIrOrzrr{rr|rr}rrJrPrKrQrLrRrMrSr7r3)r~rcr{rryrrIrOrzrr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcr{rryrrIrOrzrr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr{rr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr|rr}rrr.rJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr|rr}rrrrJrPrKrQrLrRrMrSr7r__name__ __module__ __qualname__rr?rArDrGrrarmrsrwrrrrr=r=r=r>r4@    6&/"999(c @r6)[r5r7r cCr8r9)r r:r;r=r=r>r? r@zAsyncThreads.runsrcCr8r9)rr:r;r=r=r>rA$r@zAsyncThreads.messagesAsyncThreadsWithRawResponsecCrCr9)rr;r=r=r>rD(rEzAsyncThreads.with_raw_response!AsyncThreadsWithStreamingResponsecCrCr9)rr;r=r=r>rG,rEz$AsyncThreads.with_streaming_responseNrHrArNrIrOrJrPrKrQrLrRrMrSr&c sJddi|pi}|jdt||dtjIdHt||||dtdIdHS)rTrUrVrWrXNrYrZ)r^rr)r_r,r&r`r=r=r>ra0s  zAsyncThreads.createrYrbrccL|s td|ddi|pi}|jd|t||||dtdIdHS)rerfrUrVrgrYrhNrirlr=r=r>rm` zAsyncThreads.retrieveroc s`|s td|ddi|pi}|jd|td|itjIdHt||||dtdIdHS) rprfrUrVrgrINrYrZ)rjr^rr*rqr,r&rrr=r=r>rss zAsyncThreads.updater'cr)rtrfrUrVrgrYrhNrurlr=r=r>rwrzAsyncThreads.deleterxr~ryrrzr{rr|rr}rr3c dSrr=rr=r=r>r8zAsyncThreads.create_and_runrr!AsyncStream[AssistantStreamEvent]c rrr=rr=r=r>rrr'Run | AsyncStream[AssistantStreamEvent]c rrr=rr=r=r>rArrc s`ddi|pi}|jdt|||||||dtjIdHt|| | | dt|p'dttdIdHSr)r^rr+rr,r3r%r(rr=r=r>r{s,   7AsyncAssistantStreamManager[AsyncAssistantEventHandler]c Crrr=rr=r=r>rrz"AsyncThreads.create_and_run_streamrr18AsyncAssistantStreamManager[AsyncAssistantEventHandlerT]c Crrr=rr=r=r>rrr"AsyncAssistantEventHandlerT | NonerAsyncAssistantStreamManager[AsyncAssistantEventHandler] | AsyncAssistantStreamManager[AsyncAssistantEventHandlerT]c Csldd|rdndd|p i}|jdt||||d||dtjt|| | | d tdttd } t| |p3t d Sr) r^rr+rr,r3r%r(r2r0) r<r~ryrIrzr|r}rrJrKrLrMrequestr=r=r>rs6   )r7r )r7r)r7r)r7rrrrrr)r~rcr{rryrrIrOrzrr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcr{rryrrIrOrzrr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr{rr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr|rr}rrJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr|rr}rrr1rJrPrKrQrLrRrMrSr7r)r~rcryrrIrOrzrr|rr}rrrrJrPrKrQrLrRrMrSr7rrr=r=r=r>r5rc@2eZdZdddZeddd Zedd d Zd S)rBthreadsr4r7NonecCP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr9)_threadsr to_raw_response_wrapperrarmrsrwrr<rr=r=r>__init__  zThreadsWithRawResponse.__init__r cC t|jjSr9)r rr?r;r=r=r>r? zThreadsWithRawResponse.runsrcCrr9)rrrAr;r=r=r>rArzThreadsWithRawResponse.messagesNrr4r7r)r7r )r7rrrrrrr?rAr=r=r=r>rB   rBc@r)rrr5r7rcCrr9)rr async_to_raw_response_wrapperrarmrsrwrrr=r=r>rrz$AsyncThreadsWithRawResponse.__init__rcCrr9)rrr?r;r=r=r>r?1rz AsyncThreadsWithRawResponse.runsrcCrr9)rrrAr;r=r=r>rA5rz$AsyncThreadsWithRawResponse.messagesNrr5r7r)r7r)r7rrr=r=r=r>rrrc@r)rFrr4r7rcCF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr9)rr"rarmrsrwrrr=r=r>r;  z%ThreadsWithStreamingResponse.__init__rcCrr9)rrr?r;r=r=r>r?Nrz!ThreadsWithStreamingResponse.runsrcCrr9)rrrAr;r=r=r>rARrz%ThreadsWithStreamingResponse.messagesNr)r7r)r7rrr=r=r=r>rF:rrFc@r)rrr5r7rcCrr9)rr#rarmrsrwrrr=r=r>rXrz*AsyncThreadsWithStreamingResponse.__init__rcCrr9)rrr?r;r=r=r>r?krz&AsyncThreadsWithStreamingResponse.runsrcCrr9)rrrAr;r=r=r>rAorz*AsyncThreadsWithStreamingResponse.messagesNr)r7r)r7rrr=r=r=r>rWrr)K __future__rtypingrrr functoolsrtyping_extensionsrhttpxr r?r r r rrrrArrrrrr_typesrrrrr_utilsrrr runs.runs_compatr _resourcer r! _responser"r# _streamingr$r% types.betar&r'r(r)r*r+ _base_clientr, lib.streamingr-r.r/r0r1r2messages.messagestypes.beta.threadsr3__all__r4r5rBrrFrr=r=r=r>sB           bd