fj ddlmZddlmZmZmZddlmZddlm Z ddl Z ddl m Z dd l mZmZmZmZmZmZdd lmZmZmZmZmZdd lmZmZmZdd lmZdd l m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8ddl9m:Z:m;Z;mZ>ddgZ?Gdde!Z@Gdde"ZAGddZBGddZCGddZDGdd ZEdS)!) annotations)IterableOptionaloverload)partial)LiteralN)_legacy_response)Steps AsyncStepsStepsWithRawResponseAsyncStepsWithRawResponseStepsWithStreamingResponseAsyncStepsWithStreamingResponse) NOT_GIVENBodyQueryHeadersNotGiven) required_argsmaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)Stream AsyncStream)SyncCursorPageAsyncCursorPage)AssistantToolParamAssistantStreamEvent)AsyncPaginatormake_request_options)AssistantEventHandlerAssistantEventHandlerTAssistantStreamManagerAsyncAssistantEventHandlerAsyncAssistantEventHandlerTAsyncAssistantStreamManager)Runrun_list_paramsrun_create_paramsrun_update_paramsrun_submit_tool_outputs_paramsRuns AsyncRunsc eZdZedPdZedQdZedRdZeeeeeeeddded dSd Z eeeeeeddded! dTd$Z eeeeeeddded! dUd'Z e d gd dgeeeeeeddded dVd)Z ddded*dWd,Z eddded-dXd.Z eeeeddded/dYd8Z ddded*dWd9Zeeeeeeddded! dZd;Zeeeeeeddded! d[d?Zeeeeedddded@ d\dCZeedddedDd]dGZeddded*d^dHZeddded*d_dIZe d dEggdJedddedDd`dKZeddded*dadLZeddded*dbdMZddddedNdcdOZdS)dr2returnr c*t|jSN)r _clientselfs {C:\Users\Terasoftware\OneDrive\Desktop\faahhh\fyndo\fyndo\venv\Lib\site-packages\openai/resources/beta/threads/runs/runs.pystepsz Runs.steps8sT\"""RunsWithRawResponsec t|Sr7)r>r9s r;with_raw_responsezRuns.with_raw_response<s"4(((r=RunsWithStreamingResponsec t|Sr7)rAr9s r;with_streaming_responsezRuns.with_streaming_response@s(...r=N additional_instructions instructionsmetadatamodelstreamtools extra_headers extra_query extra_bodytimeout thread_idstr assistant_idrEOptional[str] | NotGivenrFrGOptional[object] | NotGivenrHrI#Optional[Literal[False]] | NotGivenrJ1Optional[Iterable[AssistantToolParam]] | NotGivenrKHeaders | NonerL Query | NonerM Body | NonerN'float | httpx.Timeout | None | NotGivenr-c dSa Create a run. Args: assistant_id: The ID of the [assistant](https://platform.openai.com/docs/api-reference/assistants) to use to execute this run. additional_instructions: Appends additional instructions at the end of the instructions for the run. This is useful for modifying the behavior on a per-run basis without overriding other instructions. instructions: Overrides the [instructions](https://platform.openai.com/docs/api-reference/assistants/createAssistant) 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. 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 N r:rOrQrErFrGrHrIrJrKrLrMrNs r;createz Runs.createD x r= rErFrGrHrJrKrLrMrN Literal[True]Stream[AssistantStreamEvent]c dSa Create a run. 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. additional_instructions: Appends additional instructions at the end of the instructions for the run. This is useful for modifying the behavior on a per-run basis without overriding other instructions. instructions: Overrides the [instructions](https://platform.openai.com/docs/api-reference/assistants/createAssistant) 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. 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:rOrQrIrErFrGrHrJrKrLrMrNs r;r^z Runs.creater_r=bool"Run | Stream[AssistantStreamEvent]c dSrdr\res r;r^z Runs.creater_r=3Optional[Literal[False]] | Literal[True] | NotGivenc |std|ddi| pi} |d|dt|||||||dtjt | | | | t |pdtt S N8Expected a non-empty value for `thread_id` but received OpenAI-Beta assistants=v1 /threads//runsrQrErFrGrHrIrJrKrLrMrNFbodyoptionscast_torI stream_cls) ValueError_postrr/RunCreateParamsr&r-rr$r]s r;r^z Runs.creates& geXaeeff f&QM)r5rArOrPrQrPrErRrFrRrGrSrHrRrIrTrJrUrKrVrLrWrMrXrNrYr5r-)rOrPrQrPrIrarErRrFrRrGrSrHrRrJrUrKrVrLrWrMrXrNrYr5rb)rOrPrQrPrIrfrErRrFrRrGrSrHrRrJrUrKrVrLrWrMrXrNrYr5rg)rOrPrQrPrErRrFrRrGrSrHrRrIrirJrUrKrVrLrWrMrXrNrYr5rgr{rPrOrPrKrVrLrWrMrXrNrYr5r-r{rPrOrPrGrSrKrVrLrWrMrXrNrYr5r-)rOrPrrrrrrrrrKrVrLrWrMrXrNrYr5r)rQrPrErRrFrRrGrSrHrRrJrUrOrPrKrVrLrWrMrXrNrYr5r)rQrPrErRrFrRrGrSrHrRrJrUrOrPrr(rKrVrLrWrMrXrNrYr5r)rQrPrErRrFrRrGrSrHrRrJrUrOrPrrrKrVrLrWrMrXrNrYr5rr{rPrOrPrrrIrTrKrVrLrWrMrXrNrYr5r-)r{rPrOrPrIrarrrKrVrLrWrMrXrNrYr5rb)r{rPrOrPrIrfrrrKrVrLrWrMrXrNrYr5rg)r{rPrOrPrrrIrirKrVrLrWrMrXrNrYr5rg)rrr{rPrOrPrKrVrLrWrMrXrNrYr5r)rrr{rPrOrPrr(rKrVrLrWrMrXrNrYr5r)rrr{rPrOrPrrrKrVrLrWrMrXrNrYr5r__name__ __module__ __qualname__rr<r@rCrrr^rrrrrrrrr\r=r;r2r27s###_#)))_)///_/ =F1:09*36?CL)-$("&;D!; ; ; ; ; X; z=F1:09*3CL)-$("&;D!; ; ; ; ; X; z=F1:09*3CL)-$("&;D!; ; ; ; ; X; z]N#nh%?@@ =F1:09*3FOCL)-$("&;D!) ) ) ) ) A@) d)-$("&;D# # # # # # T1:)-$("&;D* * * * * * `!*!* )3<)-$("&;DA A A A A A T)-$("&;D# # # # # # J =F1:09*3CL)-$("&;D     X ( =F1:09*3CL )-$("&;D!     X 2=F1:09*3CL7;)-$("&;D!2l2l2l2l2l2lh7@)-$("&;D# # # # # X# J)-$("&;D# # # # # X# J)-$("&;D# # # # # X# J]K02Y2Y2YZZGP)-$("&;D" " " " " [Z" H)-$("&;D     X &)-$("&;D     X 48<)-$("&;D/g/g/g/g/g/g/g/gr=c eZdZedPdZedQdZedRdZeeeeeeeddded dSd Z eeeeeeddded! dTd$Z eeeeeeddded! dUd'Z e d gd dgeeeeeeddded dVd)Z ddded*dWd,Z eddded-dXd.Z eeeeddded/dYd8Z ddded*dWd9Zeeeeeeddded! dZd;Zeeeeeeddded! d[d?Zeeeeedddded@ d\dCZeedddedDd]dGZeddded*d^dHZeddded*d_dIZe d dEggdJedddedDd`dKZeddded*dadLZeddded*dbdMZddddedNdcdOZdS)dr3r5r c*t|jSr7)r r8r9s r;r<zAsyncRuns.steps5s$,'''r=AsyncRunsWithRawResponsec t|Sr7)rr9s r;r@zAsyncRuns.with_raw_response9s'---r=AsyncRunsWithStreamingResponsec t|Sr7)rr9s r;rCz!AsyncRuns.with_streaming_response=s-d333r=NrDrOrPrQrErRrFrGrSrHrIrTrJrUrKrVrLrWrMrXrNrYr-c  KdSr[r\r]s r;r^zAsyncRuns.createAx r=r`ra!AsyncStream[AssistantStreamEvent]c  KdSrdr\res r;r^zAsyncRuns.createrr=rf'Run | AsyncStream[AssistantStreamEvent]c  KdSrdr\res r;r^zAsyncRuns.createrr=ric $K|std|ddi| pi} |d|dt|||||||dtjd{Vt | | | | t |pdtt d{VSrk) rxryrr/rzr&r-r r$r]s r;r^zAsyncRuns.creates & geXaeeff f&QMrunsr2r5Nonec|||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSr7) _runsr to_raw_response_wrapperr^rrrrrr:rs r;__init__zRunsWithRawResponse.__init__6s &> K   )@ M   '> K   %< I   '> K   $4#K  $$ $    r=rc4t|jjSr7)rrr<r9s r;r<zRunsWithRawResponse.stepsLs#DJ$4555r=Nrr2r5r)r5rrrrrrr<r\r=r;r>r>5sH    ,666_666r=r>c.eZdZd dZed dZdS) rrr3r5rc|||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSr7) rr async_to_raw_response_wrapperr^rrrrrrs r;rz!AsyncRunsWithRawResponse.__init__Rs &D K   )F M   'D K   %B I   'D K   $4#Q  $$ $    r=rc4t|jjSr7)rrr<r9s r;r<zAsyncRunsWithRawResponse.stepshs()9:::r=Nrr3r5r)r5rr r\r=r;rrQsH    ,;;;_;;;r=rc.eZdZd dZed dZdS) rArr2r5rc@||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSr7)rrr^rrrrrrs r;rz"RunsWithStreamingResponse.__init__ns 2 K   5 M   3 K   1 I   3 K   $@  $$ $    r=rc4t|jjSr7)rrr<r9s r;r<zRunsWithStreamingResponse.stepss)$**:;;;r=Nr )r5rr r\r=r;rArAmsH    ,<<<_<<rrArr\r=r;r(s#"""""//////////%%%%%% """"""BAAAAAAAAAAAAA )(((((<<<<<<<<[[[[[[[[////////;;;;;;;;DDDDDDDD ; z gz gz gz gz g?z gz gz gz~ q~ q~ q~ q~ q ~ q~ q~ qB666666668;;;;;;;;8<<<<<<<<8AAAAAAAAAAr=