U hv@s|ddlmZddlZddlZddlmZmZddlmZddlZddl m Z ddl m Z m Z mZddlmZmZmZmZmZmZdd lmZmZmZmZdd lmZdd lmZmZdd 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-m.Z.ddl/m0Z0ddl1m Z ddgZ2GdddeZ3GdddeZ4GdddZ5GdddZ6GdddZ7GdddZ8dS)) annotationsN)Mappingcast)Literal)_legacy_response) FilePurposefile_list_paramsfile_create_params) NOT_GIVENBodyQueryHeadersNotGiven FileTypes) 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 @sBeZdZeddddZeddddZeddded d d d d dddddddZdddeddd dddddddZeeeedddedddddd ddddd d d!Z dddeddd dddd"dd#d$Z dddeddd dddd%dd&d'Z e d(dddeddd dddddd)d*Zd+d,d-dd.d.dd/d0d1ZdS)2r$FilesWithRawResponsereturncCst|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,:/tmp/pip-unpacked-wheel-dms8d3uv/openai/resources/files.pywith_raw_response$szFiles.with_raw_responseFilesWithStreamingResponsecCst|Sz 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 )r/r*r,r,r-with_streaming_response.szFiles.with_streaming_responseN expires_after extra_headers extra_query extra_bodytimeoutrr*file_create_params.ExpiresAfter | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr"filepurposer3r4r5r6r7r(c Csft|||d}tttttf|dggd} ddi|p:i}|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?r3r>paths Content-Typemultipart/form-data/filesr4r5r6r7bodyfilesoptionscast_to) rrrrstrobject_postrr FileCreateParamsr!r" r+r>r?r3r4r5r6r7rIrJr,r,r-create7s(8 z Files.createrGrMfile_idr4r5r6r7r(cCs4|std||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/rGrKrL ValueError_getr!r"r+rTr4r5r6r7r,r,r-retrieveszFiles.retrieveafterlimitorderr?r4r5r6r7str | NotGivenint | NotGiven#Literal[('asc', 'desc')] | NotGivenzSyncCursorPage[FileObject] r_r`rar?r4r5r6r7r(c Cs6|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 rF)r_r`rar?)r4r5r6r7query)pagerKmodel) _get_api_listrr"r!rr FileListParams r+r_r`rar?r4r5r6r7r,r,r-lists&(z Files.listr#cCs4|std||jd|t||||dtdS)B Delete a 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 rVrWrGrXrZ_deleter!r#r\r,r,r-deletesz Files.delete+_legacy_response.HttpxBinaryResponseContentcCsH|std|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 rVAcceptapplication/binaryrW/contentrGrXrZr[r!rZHttpxBinaryResponseContentr\r,r,r-contents z Files.content.The `.content()` method should be used insteadcCs6|std||jd|dt||||dtdS)rsrVrWrvrGrXrZr[r!rMr\r,r,r-retrieve_content&s zFiles.retrieve_content@ poll_intervalmax_wait_secondsfloatidrrr(cCsfdddh}t}||}|j|krb||||}t||krtd|d|dq|S)EWaits for the given file to be processed, default timeout is 30 mins. processederrordeletedGiving up on waiting for file  to finish processing after seconds.timer]statusZ_sleep RuntimeErrorr+rrrZTERMINAL_STATESstartr>r,r,r-wait_for_processingHs     zFiles.wait_for_processing__name__ __module__ __qualname__rr.r1r rRr]rmrqrxtyping_extensions deprecatedr{rr,r,r,r-r$#sV   T$"C'"%c @sBeZdZeddddZeddddZeddded d d d d dddddddZdddeddd dddddddZeeeedddedddddd ddddd d d!Z dddeddd dddd"dd#d$Z dddeddd dddd%dd&d'Z e d(dddeddd dddddd)d*Zd+d,d-dd.d.dd/d0d1ZdS)2r%AsyncFilesWithRawResponser'cCst|Sr))rr*r,r,r-r.aszAsyncFiles.with_raw_responseAsyncFilesWithStreamingResponsecCst|Sr0)rr*r,r,r-r1ksz"AsyncFiles.with_streaming_responseNr2rrr8r9r:r;r<r"r=c srt|||d}tttttf|dggd} ddi|p:i}|jdt|tj IdH| t ||||dt d IdHS) r@rAr>rBrDrErFNrGrH) rrrrrMrNrOrr rPr!r"rQr,r,r-rRts(8zAsyncFiles.createrGrMrScs:|std||jd|t||||dtdIdHS)rUrVrWrGrXNrYr\r,r,r-r]szAsyncFiles.retriever^rbrcrdz7AsyncPaginator[FileObject, AsyncCursorPage[FileObject]]rec Cs6|jdttt||||t||||dtjdtdSrf)rjrr"r!rr rkrlr,r,r-rms&(zAsyncFiles.listr#cs:|std||jd|t||||dtdIdHS)rnrVrWrGrXNror\r,r,r-rq szAsyncFiles.deleterrcsN|std|ddi|pi}|jd|dt||||dtjdIdHS) rsrVrtrurWrvrGrXNrwr\r,r,r-rxAs zAsyncFiles.contentrycs<|std||jd|dt||||dtdIdHS)rsrVrWrvrGrXNrzr\r,r,r-r{cs zAsyncFiles.retrieve_contentr|r}r~rrcsxdddh}t}||IdH}|j|krt||IdH||IdH}t||kr"td|d|dq"|S)rrrrNrrrrrr,r,r-rs  zAsyncFiles.wait_for_processingrr,r,r,r-r%`sV   T$"C'"%c@seZdZdddddZdS)r&r$NonerJr(cCs^||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSN) _filesrZto_raw_response_wrapperrRr]rmrqrxr{r+rJr,r,r-__init__s(zFilesWithRawResponse.__init__Nrrrrr,r,r,r-r&sr&c@seZdZdddddZdS)rr%rrcCs^||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSr) rrZasync_to_raw_response_wrapperrRr]rmrqrxr{rr,r,r-rs(z"AsyncFilesWithRawResponse.__init__Nrr,r,r,r-rsrc@seZdZdddddZdS)r/r$rrcCsT||_t|j|_t|j|_t|j|_t|j|_t|jt|_t|j |_ dSr) rrrRr]rmrqrrxrr{rr,r,r-rs*z#FilesWithStreamingResponse.__init__Nrr,r,r,r-r/sr/c@seZdZdddddZdS)rr%rrcCsT||_t|j|_t|j|_t|j|_t|j|_t|jt|_t|j |_ dSr) rrrRr]rmrqrrxrr{rr,r,r-rs*z(AsyncFilesWithStreamingResponse.__init__Nrr,r,r,r-rsr)9 __future__rrrtypingrrrZhttpxrtypesrr r _typesr r r rrr_utilsrrrr_compatrZ _resourcerr _responserrrrrrZ paginationrrZ _base_clientr r!Ztypes.file_objectr"Ztypes.file_deletedr#Ztypes.file_purpose__all__r$r%r&rr/rr,r,r,r-s8         ??