a !fhg@s,ddlmZddlmZmZmZddlmZddlZddl m Z m Z m Z m Z ddlmZmZmZmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd lm Z m!Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'erddl(m)Z)m*Z*ddgZ+GdddeZ,GdddeZ-GdddZ.GdddZ/dS)) annotations) TYPE_CHECKINGListOptional)LiteralN)Steps AsyncStepsStepsWithRawResponseAsyncStepsWithRawResponse) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transform)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperasync_to_raw_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)Runrun_list_paramsrun_create_paramsrun_update_paramsrun_submit_tool_outputs_params)OpenAI AsyncOpenAIRuns AsyncRunsc s>eZdZUded<ded<dddfdd Zeeeed d d ed d d d dd ddddddd ddZd d d edd d ddddddddZed d d edd d dddddddddZeeeed d d ed d d!d!d"d#ddddd$d% d&d'Z d d d edd d ddddddd(d)Z d d d edd d d*dddddd+d,d-Z Z S).r"rstepsRunsWithRawResponsewith_raw_responser Noneclientreturncs$t|t||_t||_dSN)super__init__rr$r%r&selfr) __class__h/var/www/html/python-backend/venv/lib/python3.9/site-packages/openai/resources/beta/threads/runs/runs.pyr-#s  z Runs.__init__N instructionsmetadatamodeltools extra_headers extra_query extra_bodytimeoutstrOptional[str] | NotGivenOptional[object] | NotGiven1Optional[List[run_create_params.Tool]] | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr thread_id assistant_idr5r6r7r8r9r:r;r<r*c CsJddi|p i}|jd|dt|||||dtjt||| | dtdS) 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. 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. 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 OpenAI-Beta assistants=v1 /threads//runsrGr5r6r7r8r9r:r;r<bodyoptionscast_to_postrrZRunCreateParamsrr r/rFrGr5r6r7r8r9r:r;r<r2r2r3create(s"0  z Runs.createrNrun_idrFr9r:r;r<r*cCs8ddi|p i}|jd|d|t||||dtdS)D Retrieves a run. 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 rIrJrK/runs/rNrQrR_getrrr/rXrFr9r:r;r<r2r2r3retrieveksz Runs.retriever6r9r:r;r<rXrFr6r9r:r;r<r*c CsFddi|p i}|jd|d|td|itjt||||dtdS)} Modifies a run. 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 rIrJrKrZr6rNrOrTrrZRunUpdateParamsrrr/rXrFr6r9r:r;r<r2r2r3updatesz Runs.updateafterbeforelimitorderr9r:r;r<str | NotGivenint | NotGiven!Literal['asc', 'desc'] | NotGivenzSyncCursorPage[Run] rFrgrhrirjr9r:r;r<r*c CsNddi|p i}|jd|dttt|||| t||||dtjdtdSa Returns a list of runs belonging to a thread. Args: after: A cursor for use in pagination. `after` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include after=obj_foo in order to fetch the next page of the list. before: A cursor for use in pagination. `before` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include before=obj_foo in order to fetch the previous page of the list. limit: A limit on the number of objects to be returned. Limit can range between 1 and 100, and the default is 20. order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. 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 rIrJrKrL)rgrhrirj)r9r:r;r<query)pagerQr7) _get_api_listrrrrr RunListParams r/rFrgrhrirjr9r:r;r<r2r2r3lists(+ z Runs.listcCs:ddi|p i}|jd|d|dt||||dtdS)X Cancels a run that is `in_progress`. 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 rIrJrKrZ/cancelrNr[rTrrr^r2r2r3cancelsz Runs.cancel/List[run_submit_tool_outputs_params.ToolOutput]rXrF tool_outputsr9r:r;r<r*c CsHddi|p i}|jd|d|dtd|itjt||||dtdS)  When a run has the `status: "requires_action"` and `required_action.type` is `submit_tool_outputs`, this endpoint can be used to submit the outputs from the tool calls once they're all completed. All outputs must be submitted in a single request. Args: tool_outputs: A list of tools for which the outputs are being submitted. 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 rIrJrKrZ/submit_tool_outputsr|rNrOrTrrZRunSubmitToolOutputsParamsrrr/rXrFr|r9r:r;r<r2r2r3submit_tool_outputss zRuns.submit_tool_outputs __name__ __module__ __qualname____annotations__r-r rVr_reruryr __classcell__r2r2r0r3r"sT  &J& ,$H)c s>eZdZUded<ded<dddfdd Zeeeed d d ed d d d dd ddddddd ddZd d d edd d ddddddddZed d d edd d dddddddddZeeeed d d ed d d!d!d"d#ddddd$d% d&d'Z d d d edd d ddddddd(d)Z d d d edd d d*dddddd+d,d-Z Z S).r#r r$AsyncRunsWithRawResponser&r!r'r(cs$t|t||_t||_dSr+)r,r-r r$rr&r.r0r2r3r-Es  zAsyncRuns.__init__Nr4r=r>r?r@rArBrCrDrrEc sPddi|p i}|jd|dt|||||dtjt||| | dtdIdHS) rHrIrJrKrLrMrNrONrSrUr2r2r3rVJs"0  zAsyncRuns.createrNrWcs>ddi|p i}|jd|d|t||||dtdIdHS)rYrIrJrKrZrNr[Nr\r^r2r2r3r_szAsyncRuns.retriever`rac sLddi|p i}|jd|d|td|itjt||||dtdIdHS) rbrIrJrKrZr6rNrONrcrdr2r2r3reszAsyncRuns.updaterfrkrlrmz)AsyncPaginator[Run, AsyncCursorPage[Run]]rnc CsNddi|p i}|jd|dttt|||| t||||dtjdtdSro)rrrrrrrrsrtr2r2r3rus(+ zAsyncRuns.listcs@ddi|p i}|jd|d|dt||||dtdIdHS) rvrIrJrKrZrwrNr[Nrxr^r2r2r3ryszAsyncRuns.cancelrzr{c sNddi|p i}|jd|d|dtd|itjt||||dtdId HS) r}rIrJrKrZr~r|rNrONrrr2r2r3r8s zAsyncRuns.submit_tool_outputsrr2r2r0r3r#AsT  &J& ,$H)c@seZdZdddddZdS)r%r"r'runsr*cCsXt|j|_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSr+) r r$rrVr_reruryrr/rr2r2r3r-ds& zRunsWithRawResponse.__init__Nrrrr-r2r2r2r3r%csr%c@seZdZdddddZdS)rr#r'rcCsXt|j|_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSr+) r r$rrVr_reruryrrr2r2r3r-|s& z!AsyncRunsWithRawResponse.__init__Nrr2r2r2r3r{sr)0 __future__rtypingrrrZtyping_extensionsrZhttpxr$rr r r _typesr rrrr_utilsrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.threadsrrrrrZ_clientr r!__all__r"r#r%rr2r2r2r3s,   $$