a !f^T@s0ddlmZddlmZmZmZddlZddlmZm Z m Z m Z ddl m Z mZmZmZddlmZmZmZmZmZdd lmZdd lmZmZdd lmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$dd l%m&Z&ddl'm(Z(erddl)m*Z*m+Z+ddgZ,GdddeZ-GdddeZ.GdddZ/GdddZ0dS)) annotations) TYPE_CHECKINGListOptionalN)Runs AsyncRunsRunsWithRawResponseAsyncRunsWithRawResponse)Messages AsyncMessagesMessagesWithRawResponseAsyncMessagesWithRawResponse) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transform)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperasync_to_raw_response_wrapper)Thread ThreadDeletedthread_create_paramsthread_update_paramsthread_create_and_run_params)make_request_options)Run)OpenAI AsyncOpenAIThreads AsyncThreadsc seZdZUded<ded<ded<ddd fd d Zeed d d ed ddddddddddZd d d eddddddddddZed d d eddddddddddd Zd d d eddddddd!dd"d#Z eeeeed d d ed$ dd%dd%d&d'ddddd(d) d*d+Z Z S),r#rrunsr messagesThreadsWithRawResponsewith_raw_responser!Noneclientreturncs.t|t||_t||_t||_dSN)super__init__rr%r r&r'r(selfr+ __class__f/var/www/html/python-backend/venv/lib/python3.9/site-packages/openai/resources/beta/threads/threads.pyr/)s   zThreads.__init__Nr&metadata extra_headers extra_query extra_bodytimeout-List[thread_create_params.Message] | NotGivenOptional[object] | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenrr&r7r8r9r:r;r,c Cs<ddi|p i}|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/threadsr&r7r8r9r:r;bodyoptionscast_to_postrrZThreadCreateParamsrrr1r&r7r8r9r:r;r4r4r5create/s zThreads.createrHstr thread_idr8r9r:r;r,cCs2ddi|p i}|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 rDrE /threads/rHrKrL_getrrr1rSr8r9r:r;r4r4r5retrieve_szThreads.retriever7r8r9r:r;rSr7r8r9r:r;r,c Cs@ddi|p i}|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 rDrErUr7rHrIrNrrZThreadUpdateParamsrrr1rSr7r8r9r:r;r4r4r5updateszThreads.updatercCs2ddi|p i}|jd|t||||dtdS)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 rDrErUrHrV_deleterrrYr4r4r5deleteszThreads.delete instructionsr7modelthreadtoolsr8r9r:r;Optional[str] | NotGiven.thread_create_and_run_params.Thread | NotGivenr?r@rArrBc sBddi|p i}|jdt||dtjt||||dtdIdHS)rCrDrErFrGrHrINrMrOr4r4r5rPs zAsyncThreads.createrHrQrRcs8ddi|p i}|jd|t||||dtdIdHS)rTrDrErUrHrVNrWrYr4r4r5rZHszAsyncThreads.retriever[r\c sFddi|p i}|jd|td|itjt||||dtdIdHS)r]rDrErUr7rHrINr^r_r4r4r5r`hszAsyncThreads.updatercs8ddi|p i}|jd|t||||dtdIdHS)rarDrErUrHrVNrbrYr4r4r5rdszAsyncThreads.deletererjrkrlr rmc sJddi|p i}|jdt||||||dtjt||| | dtdIdHS)rorDrErprqrHrINrrrsr4r4r5rts$2 zAsyncThreads.create_and_runrur4r4r2r5r$ sJ  6$-$c@seZdZdddddZdS)r'r#r)threadsr,cCsXt|j|_t|j|_t|j|_t|j|_t|j|_t|j|_t|j |_ dSr-) r r%r r&rrPrZr`rdrtr1r}r4r4r5r/s"  zThreadsWithRawResponse.__init__Nrvrwrxr/r4r4r4r5r'sr'c@seZdZdddddZdS)r{r$r)r|cCsXt|j|_t|j|_t|j|_t|j|_t|j|_t|j|_t|j |_ dSr-) r r%rr&rrPrZr`rdrtr~r4r4r5r/ s"  z$AsyncThreadsWithRawResponse.__init__Nrr4r4r4r5r{ sr{)1 __future__rtypingrrrZhttpxr%rrr r r&r r r r_typesrrrrr_utilsrZ _resourcerr _responserrZ types.betarrrrrZ _base_clientrZtypes.beta.threadsr Z_clientr!r"__all__r#r$r'r{r4r4r4r5s(    jj