o $iv@sddlmZddlZddlZddlmZmZddlmZddlZddl m Z ddl m Z m Z mZddlmZmZmZmZmZmZmZmZdd lmZmZmZmZdd lmZdd lm Z m!Z!dd l"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*m+Z+ddl,m-Z-m.Z.ddl/m0Z0ddl1m2Z2ddl3m Z ddgZ4Gddde Z5Gddde!Z6GdddZ7GdddZ8GdddZ9GdddZ:dS)) annotationsN)Mappingcast)Literal)_legacy_response) FilePurposefile_list_paramsfile_create_params)BodyOmitQueryHeadersNotGiven FileTypesomit not_given) extract_filesmaybe_transformdeepcopy_minimalasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)StreamedBinaryAPIResponseAsyncStreamedBinaryAPIResponseto_streamed_response_wrapper"async_to_streamed_response_wrapper#to_custom_streamed_response_wrapper)async_to_custom_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options) FileObject) FileDeleted)rFiles AsyncFilesc @eZdZedddZdddedd?ddZ eeeeddded d@d(d)Z dddeddAd+d,Z dddeddBd.d/Z e d0dddeddCd1d2Zd3d4d5dDd:d;ZdS)Er&returnFilesWithRawResponsecCt|Sa This property can be used as a prefix for any HTTP method call to return 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 )r*selfr/V/var/www/html/flask_server/venv/lib/python3.10/site-packages/openai/resources/files.pywith_raw_response$zFiles.with_raw_responseFilesWithStreamingResponsecCr+z 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 )r3r-r/r/r0with_streaming_response.zFiles.with_streaming_responseN expires_after extra_headers extra_query extra_bodytimeoutfilerpurposerr8&file_create_params.ExpiresAfter | Omitr9Headers | Noner: Query | Noner; Body | Noner<'float | httpx.Timeout | None | NotGivenr$c Csft|||d}tttttf|dggd} ddi|pi}|jdt|tj | t ||||dt dS) Upload a file that can be used across various endpoints. Individual files can be up to 512 MB, and the size of all files uploaded by one organization can be up to 1 TB. - The Assistants API supports files up to 2 million tokens and of specific file types. See the [Assistants Tools guide](https://platform.openai.com/docs/assistants/tools) for details. - The Fine-tuning API only supports `.jsonl` files. The input also has certain required formats for fine-tuning [chat](https://platform.openai.com/docs/api-reference/fine-tuning/chat-input) or [completions](https://platform.openai.com/docs/api-reference/fine-tuning/completions-input) models. - The Batch API only supports `.jsonl` files up to 200 MB in size. The input also has a specific required [format](https://platform.openai.com/docs/api-reference/batch/request-input). Please [contact us](https://help.openai.com/) if you need to increase these storage limits. Args: file: The File object (not file name) to be uploaded. purpose: The intended purpose of the uploaded file. One of: - `assistants`: Used in the Assistants API - `batch`: Used in the Batch API - `fine-tune`: Used for fine-tuning - `vision`: Images used for vision fine-tuning - `user_data`: Flexible file type for any purpose - `evals`: Used for eval data sets expires_after: The expiration policy for a file. By default, files with `purpose=batch` expire after 30 days and all other files are persisted until they are manually deleted. 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 r=r>r8r=paths Content-Typemultipart/form-data/filesr9r:r;r<bodyfilesoptionscast_to) rrrrstrobject_postrr FileCreateParamsr#r$ r.r=r>r8r9r:r;r<rMrNr/r/r0create7s"7 z Files.createrKfile_idrQcC4|s td||jd|t||||dtdS)^ Returns information about a specific file. 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 6Expected a non-empty value for `file_id` but received /files/rKrOrP ValueError_getr#r$r.rWr9r:r;r<r/r/r0retrievezFiles.retrieveafterlimitorderr>r9r:r;r<rd str | Omitre int | OmitrfLiteral['asc', 'desc'] | OmitSyncCursorPage[FileObject]c C6|jdttt||||t||||dtjdtdSaReturns a list of files. 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. limit: A limit on the number of objects to be returned. Limit can range between 1 and 10,000, and the default is 10,000. order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. purpose: Only return files with the given purpose. 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 rJ)rdrerfr>)r9r:r;r<query)pagerOmodel) _get_api_listr r$r#rr FileListParams r.rdrerfr>r9r:r;r<r/r/r0list&(z Files.listr%cCrX)g Delete a file and remove it from all vector stores. 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 rZr[rKr\r^_deleter#r%r`r/r/r0deleterbz Files.delete+_legacy_response.HttpxBinaryResponseContentcCsH|s td|ddi|pi}|jd|dt||||dtjdS)_ Returns the contents of the specified file. 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 rZAcceptapplication/binaryr[/contentrKr\r^r_r#rHttpxBinaryResponseContentr`r/r/r0contents z Files.content.The `.content()` method should be used insteadcCs6|s td||jd|dt||||dtdS)rzrZr[r}rKr\r^r_r#rQr`r/r/r0retrieve_content%s zFiles.retrieve_content@ poll_intervalmax_wait_secondsidrfloatrcCslhd}t}||}|j|vr4||||}t||kr/td|d|d|j|vs|S)EWaits for the given file to be processed, default timeout is 30 mins.>errordeleted processedGiving up on waiting for file  to finish processing after seconds.timerastatus_sleep RuntimeErrorr.rrrTERMINAL_STATESstartr=r/r/r0wait_for_processingGs      zFiles.wait_for_processing)r)r*)r)r3r=rr>rr8r?r9r@r:rAr;rBr<rCr)r$ rWrQr9r@r:rAr;rBr<rCr)r$)rdrgrerhrfrir>rgr9r@r:rAr;rBr<rCr)rj rWrQr9r@r:rAr;rBr<rCr)r% rWrQr9r@r:rAr;rBr<rCr)ry rWrQr9r@r:rAr;rBr<rCr)rQrrQrrrrr)r$__name__ __module__ __qualname__rr1r5rrrVrarsrxrtyping_extensions deprecatedrrr/r/r/r0r&#X   S$C'"%c @r()Er'r)AsyncFilesWithRawResponsecCr+r,)rr-r/r/r0r1`r2zAsyncFiles.with_raw_responseAsyncFilesWithStreamingResponsecCr+r4)rr-r/r/r0r5jr6z"AsyncFiles.with_streaming_responseNr7r=rr>rr8r?r9r@r:rAr;rBr<rCr$c stt|||d}tttttf|dggd} ddi|pi}|jdt|tj IdH| t ||||dt d IdHS) rDrEr=rFrHrIrJNrKrL) rrrrrQrRrSrr rTr#r$rUr/r/r0rVss$7 zAsyncFiles.createrKrWrQc<|s td||jd|t||||dtdIdHS)rYrZr[rKr\Nr]r`r/r/r0ra zAsyncFiles.retrievercrdrgrerhrfri7AsyncPaginator[FileObject, AsyncCursorPage[FileObject]]c Crkrl)rpr!r$r#rr rqrrr/r/r0rsrtzAsyncFiles.listr%cr)rurZr[rKr\Nrvr`r/r/r0rxrzAsyncFiles.deleterycsP|s td|ddi|pi}|jd|dt||||dtjdIdHS) rzrZr{r|r[r}rKr\Nr~r`r/r/r0r?s  zAsyncFiles.contentrcs>|s td||jd|dt||||dtdIdHS)rzrZr[r}rKr\Nrr`r/r/r0ras  zAsyncFiles.retrieve_contentrrrrrrrcshd}t}||IdH}|j|vr>||IdH||IdH}t||kr9td|d|d|j|vs|S)r>rrrNrrrrrr/r/r0rs   zAsyncFiles.wait_for_processing)r)r)r)rrr)rdrgrerhrfrir>rgr9r@r:rAr;rBr<rCr)rrrrrrr/r/r/r0r'_rc@eZdZdddZdS) r*rNr&r)NonecC^||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSN) _filesrto_raw_response_wrapperrVrarsrxrrr.rNr/r/r0__init__(zFilesWithRawResponse.__init__NrNr&r)rrrrrr/r/r/r0r*r*c@r) rrNr'r)rcCrr) rrasync_to_raw_response_wrapperrVrarsrxrrrr/r/r0rrz"AsyncFilesWithRawResponse.__init__NrNr'r)rrr/r/r/r0rrrc@r) r3rNr&r)rcCT||_t|j|_t|j|_t|j|_t|j|_t|jt|_t|j |_ dSr) rrrVrarsrxrrrrrr/r/r0r*z#FilesWithStreamingResponse.__init__Nrrr/r/r/r0r3rr3c@r) rrNr'r)rcCrr) rrrVrarsrxrrrrrr/r/r0rrz(AsyncFilesWithStreamingResponse.__init__Nrrr/r/r/r0rrr); __future__rrrtypingrrrhttpxrtypesrr r _typesr r r rrrrr_utilsrrrr_compatr _resourcerr _responserrrrrr paginationr r! _base_clientr"r#types.file_objectr$types.file_deletedr%types.file_purpose__all__r&r'r*rr3rr/r/r/r0s:   (     >>